Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.streaming.api.functions.sink.filesystem | |
org.apache.flink.table.filesystem.stream |
Modifier and Type | Interface and Description |
---|---|
interface |
OperatorStateBackend
Interface that combines both, the user facing
OperatorStateStore interface and the system
interface Snapshotable |
Modifier and Type | Class and Description |
---|---|
class |
DefaultOperatorStateBackend
Default implementation of OperatorStateStore that provides the ability to make snapshots.
|
Modifier and Type | Method and Description |
---|---|
OperatorStateStore |
StateInitializationContextImpl.getOperatorStateStore() |
OperatorStateStore |
ManagedInitializationContext.getOperatorStateStore()
Returns an interface that allows for registering operator state with the backend.
|
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStateInputs,
Iterable<StatePartitionStreamProvider> rawOperatorStateInputs) |
Constructor and Description |
---|
StreamingFileSinkHelper(Buckets<IN,?> buckets,
boolean isRestored,
OperatorStateStore stateStore,
ProcessingTimeService procTimeService,
long bucketCheckInterval) |
Modifier and Type | Method and Description |
---|---|
static PartitionCommitTrigger |
PartitionCommitTrigger.create(boolean isRestored,
OperatorStateStore stateStore,
Configuration conf,
ClassLoader cl,
List<String> partitionKeys,
ProcessingTimeService procTimeService) |
Constructor and Description |
---|
PartitionTimeCommitTrigger(boolean isRestored,
OperatorStateStore stateStore,
Configuration conf,
ClassLoader cl,
List<String> partitionKeys) |
ProcTimeCommitTrigger(boolean isRestored,
OperatorStateStore stateStore,
Configuration conf,
ProcessingTimeService procTimeService) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.