Class and Description |
---|
AbstractFileSource
The base class for File Sources.
|
AbstractFileSource.AbstractFileSourceBuilder
The generic base builder.
|
ContinuousEnumerationSettings
Settings describing how to do continuous file discovery and enumeration for the file source's
continuous discovery and streaming mode.
|
FileSource
A unified data source that reads files - both in batch and in streaming mode.
|
FileSource.FileSourceBuilder
The builder for the
FileSource , to configure the various behaviors. |
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
FileSourceSplitSerializer
A serializer for the
FileSourceSplit . |
PendingSplitsCheckpoint
A checkpoint of the current state of the containing the currently pending splits that are not yet
assigned.
|
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
FileSourceSplitState
State of the reader, essentially a mutable version of the
FileSourceSplit . |
PendingSplitsCheckpoint
A checkpoint of the current state of the containing the currently pending splits that are not yet
assigned.
|
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
AbstractFileSource
The base class for File Sources.
|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
PendingSplitsCheckpoint
A checkpoint of the current state of the containing the currently pending splits that are not yet
assigned.
|
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Class and Description |
---|
FileSourceSplit
A
SourceSplit that represents a file, or a region of a file. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.