Package org.apache.flink.state.forst

Class ForStStateRequestClassifier

java.lang.Object

org.apache.flink.state.forst.ForStStateRequestClassifier

All Implemented Interfaces:

org.apache.flink.runtime.asyncprocessing.StateRequestContainer

public class ForStStateRequestClassifier
extends Object
implements org.apache.flink.runtime.asyncprocessing.StateRequestContainer

The ForSt StateRequestContainer which can classify the state requests by ForStDB requestType (Get、Put or Iterator).

Constructor Summary

Constructors

Constructor	Description
ForStStateRequestClassifier()

Method Summary

Modifier and Type	Method	Description
boolean	isEmpty()
void	offer(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?> stateRequest)
List<ForStDBGetRequest<?,?>>	pollDbGetRequests()
List<ForStDBPutRequest<?,?>>	pollDbPutRequests()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ForStStateRequestClassifier

public ForStStateRequestClassifier()

Method Detail

offer

public void offer(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?> stateRequest)

Specified by:

offer in interface org.apache.flink.runtime.asyncprocessing.StateRequestContainer

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface org.apache.flink.runtime.asyncprocessing.StateRequestContainer

pollDbGetRequests

public List<ForStDBGetRequest<?,?>> pollDbGetRequests()

pollDbPutRequests

public List<ForStDBPutRequest<?,?>> pollDbPutRequests()