Bulk Operation

SPARK-20928 exactly-once mode

SPARK-20928 watermarks

SPARK-20928 add unit tests for ContinuousDataReader hook

SPARK-20928 Control maximum epoch backlog

SPARK-20928 stateful operators

SPARK-20928 update query progress

SPARK-20928 update query.status

SPARK-20928 Support select from temp tables

SPARK-20928 Add EpochCoordinator unit tests

SPARK-20928 Refactor tests away from rate source

SPARK-20928 Add MemoryStream

SPARK-20928 continuous execution should sequence committed epochs

SPARK-20928 don't modify run id

SPARK-20928 disable task-level retry for continuous execution

SPARK-20928 Move Structured Streaming v2 APIs to streaming package

SPARK-20928 add basic continuous kafka source

SPARK-20928 Make MicroBatchExecution also support MicroBatchRead/WriteSupport

SPARK-20928 Add ContinuousExecution for continuous processing queries

SPARK-20928 refactor StreamExecution for extensibility

SPARK-20928 Add DataSourceV2 streaming APIs