public class PythonSender<IN> extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
static byte |
TYPE_ARRAY |
static byte |
TYPE_KEY_VALUE |
static byte |
TYPE_VALUE_VALUE |
Constructor and Description |
---|
PythonSender() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
hasRemaining(int group) |
void |
open(String path) |
void |
reset()
Resets this object to the post-configuration state.
|
int |
sendBuffer(Iterator i,
int group)
Extracts records from an iterator and writes them to the memory-mapped file.
|
int |
sendRecord(Object value)
Writes a single record to the memory-mapped file.
|
public static final byte TYPE_ARRAY
public static final byte TYPE_KEY_VALUE
public static final byte TYPE_VALUE_VALUE
public void open(String path) throws IOException
IOException
public void close() throws IOException
IOException
public void reset()
public int sendRecord(Object value) throws IOException
value
- record to sendIOException
public boolean hasRemaining(int group)
public int sendBuffer(Iterator i, int group) throws IOException
i
- iterator containing recordsgroup
- group to which the iterator belongs, most notably used by CoGroup-functions.IOException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.