public class CollectCoordinationRequest extends Object implements CoordinationRequest
CoordinationRequest
from the client indicating that it wants a new batch of query
results.
For an explanation of this communication protocol, see Java docs in CollectSinkFunction
.
Constructor and Description |
---|
CollectCoordinationRequest(DataInputView inView) |
CollectCoordinationRequest(String version,
long offset) |
Modifier and Type | Method and Description |
---|---|
long |
getOffset() |
String |
getVersion() |
void |
serialize(DataOutputView outView) |
public CollectCoordinationRequest(String version, long offset)
public CollectCoordinationRequest(DataInputView inView) throws IOException
IOException
public String getVersion()
public long getOffset()
public void serialize(DataOutputView outView) throws IOException
IOException
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.