public class NoopStoreSinkWriteState extends Object implements StoreSinkWriteState
StoreSinkWriteState
which stores nothing. Currently only used for append only unaware
bucket table writers.StoreSinkWriteState.StateValue, StoreSinkWriteState.StateValueFilter
Constructor and Description |
---|
NoopStoreSinkWriteState(StoreSinkWriteState.StateValueFilter stateValueFilter) |
Modifier and Type | Method and Description |
---|---|
List<StoreSinkWriteState.StateValue> |
get(String tableName,
String key) |
void |
put(String tableName,
String key,
List<StoreSinkWriteState.StateValue> stateValues) |
void |
snapshotState() |
StoreSinkWriteState.StateValueFilter |
stateValueFilter() |
public NoopStoreSinkWriteState(StoreSinkWriteState.StateValueFilter stateValueFilter)
public StoreSinkWriteState.StateValueFilter stateValueFilter()
stateValueFilter
in interface StoreSinkWriteState
@Nullable public List<StoreSinkWriteState.StateValue> get(String tableName, String key)
get
in interface StoreSinkWriteState
public void put(String tableName, String key, List<StoreSinkWriteState.StateValue> stateValues)
put
in interface StoreSinkWriteState
public void snapshotState() throws Exception
snapshotState
in interface StoreSinkWriteState
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.