Yuechen Chen created SPARK-22814:
------------------------------------

             Summary: JDBC support date/timestamp type as partitionColumn
                 Key: SPARK-22814
                 URL: https://issues.apache.org/jira/browse/SPARK-22814
             Project: Spark
          Issue Type: Improvement
          Components: Input/Output
    Affects Versions: 2.2.1, 1.6.2
            Reporter: Yuechen Chen


In spark, you can partition MySQL queries by partitionColumn.
val df = (spark.read.jdbc(url=jdbcUrl,
    table="employees",
    columnName="emp_no",
    lowerBound=1L,
    upperBound=100000L,
    numPartitions=100,
    connectionProperties=connectionProperties))
display(df)

But, partitionColumn must be a numeric column from the table.
However, there are lots of table, which has no primary key, and has some 
date/timestamp indexes.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org

Reply via email to