File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
sql/core/src/main/java/org/apache/spark/sql/sources/v2/writer Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -48,9 +48,9 @@ public interface DataWriterFactory<T> extends Serializable {
4848 * same task id but different attempt number, which means there are multiple
4949 * tasks with the same task id running at the same time. Implementations can
5050 * use this attempt number to distinguish writers of different task attempts.
51- * @param epochId A monotonically increasing id for streaming queries that are split in to discrete
52- * periods of execution. For queries that execute as a single batch, this id will
53- * always be zero.
51+ * @param epochId A monotonically increasing id for streaming queries that are split in to
52+ * discrete periods of execution. For queries that execute as a single batch, this
53+ * id will always be zero.
5454 */
5555 DataWriter <T > createDataWriter (int partitionId , int attemptNumber , long epochId );
5656}
You can’t perform that action at this time.
0 commit comments