SplitT
- the split type.@Internal public class SplitsRemoval<SplitT> extends SplitsChange<SplitT>
This type of SplitsChange
is only used when the RecordEvaluator
reports the
end of the stream.
The SplitsRemoval change between the enumerator and the reader may cause a data loss. See more details at the discussion e-mail.
Constructor and Description |
---|
SplitsRemoval(List<SplitT> splits) |
Modifier and Type | Method and Description |
---|---|
String |
toString() |
splits
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.