Uses of Interface
edu.snu.coral.common.coder.Coder

Packages that use Coder

Package	Description
edu.snu.coral.common.coder
edu.snu.coral.common.ir.edge
edu.snu.coral.compiler.frontend.beam.coder
edu.snu.coral.compiler.frontend.spark.coder
edu.snu.coral.runtime.common.plan
edu.snu.coral.runtime.common.plan.physical
edu.snu.coral.runtime.common.plan.stage
edu.snu.coral.runtime.executor.data
edu.snu.coral.runtime.executor.data.block
edu.snu.coral.runtime.executor.data.stores

Uses of Coder in edu.snu.coral.common.coder

Classes in edu.snu.coral.common.coder that implement Coder

Modifier and Type	Class and Description
class	BytesCoder A Coder which is used for an array of bytes.
static class	Coder.DummyCoder Dummy coder implementation which is not supposed to be used.

Fields in edu.snu.coral.common.coder declared as Coder

Modifier and Type	Field and Description
static Coder	Coder.DUMMY_CODER Dummy coder.

Uses of Coder in edu.snu.coral.common.ir.edge

Methods in edu.snu.coral.common.ir.edge that return Coder

Modifier and Type	Method and Description
Coder	IREdge.getCoder()

Constructors in edu.snu.coral.common.ir.edge with parameters of type Coder

Constructor and Description
IREdge(DataCommunicationPatternProperty.Value commPattern, IRVertex src, IRVertex dst, Coder coder) Constructor of IREdge.
IREdge(DataCommunicationPatternProperty.Value commPattern, IRVertex src, IRVertex dst, Coder coder, Boolean isSideInput) Constructor of IREdge.

Uses of Coder in edu.snu.coral.compiler.frontend.beam.coder

Classes in edu.snu.coral.compiler.frontend.beam.coder that implement Coder

Modifier and Type	Class and Description
class	BeamCoder<T> Coder from Coder.

Uses of Coder in edu.snu.coral.compiler.frontend.spark.coder

Classes in edu.snu.coral.compiler.frontend.spark.coder that implement Coder

Modifier and Type	Class and Description
class	SparkCoder<T> Kryo Spark Coder for serialization.

Uses of Coder in edu.snu.coral.runtime.common.plan

Methods in edu.snu.coral.runtime.common.plan that return Coder

Modifier and Type	Method and Description
Coder	RuntimeEdge.getCoder()

Constructors in edu.snu.coral.runtime.common.plan with parameters of type Coder

Constructor and Description
RuntimeEdge(String runtimeEdgeId, ExecutionPropertyMap edgeProperties, V src, V dst, Coder coder) Constructs the edge given the below parameters.
RuntimeEdge(String runtimeEdgeId, ExecutionPropertyMap edgeProperties, V src, V dst, Coder coder, Boolean isSideInput) Constructs the edge given the below parameters.

Uses of Coder in edu.snu.coral.runtime.common.plan.physical

Constructors in edu.snu.coral.runtime.common.plan.physical with parameters of type Coder

Constructor and Description
PhysicalStageEdge(String runtimeEdgeId, ExecutionPropertyMap edgeProperties, IRVertex srcVertex, IRVertex dstVertex, PhysicalStage srcStage, PhysicalStage dstStage, Coder coder, Boolean isSideInput) Constructor.

Uses of Coder in edu.snu.coral.runtime.common.plan.stage

Methods in edu.snu.coral.runtime.common.plan.stage with parameters of type Coder

Modifier and Type	Method and Description
StageEdgeBuilder	StageEdgeBuilder.setCoder(Coder c) Setter for coder.

Constructors in edu.snu.coral.runtime.common.plan.stage with parameters of type Coder

Constructor and Description
StageEdge(String irEdgeId, ExecutionPropertyMap edgeProperties, Stage srcStage, Stage dstStage, Coder coder, Boolean isSideInput, IRVertex srcVertex, IRVertex dstVertex) Represents the edge between stages.

Uses of Coder in edu.snu.coral.runtime.executor.data

Methods in edu.snu.coral.runtime.executor.data that return Coder

Modifier and Type	Method and Description
Coder	CoderManager.getCoder(String runtimeEdgeId) Return the coder for the specified runtime edge.

Methods in edu.snu.coral.runtime.executor.data with parameters of type Coder

Modifier and Type	Method and Description
static <K extends Serializable> Iterable<NonSerializedPartition<K>>	DataUtil.convertToNonSerPartitions(Coder coder, Iterable<SerializedPartition<K>> partitionsToConvert) Converts the serialized Partitions in an iterable to non-serialized Partitions.
static <K extends Serializable> Iterable<SerializedPartition<K>>	DataUtil.convertToSerPartitions(Coder coder, Iterable<NonSerializedPartition<K>> partitionsToConvert) Converts the non-serialized Partitions in an iterable to serialized Partitions.
static <K extends Serializable> NonSerializedPartition	DataUtil.deserializePartition(long elementsInPartition, Coder coder, K key, InputStream inputStream) Reads the data of a partition from an input stream and deserializes it.
void	CoderManager.registerCoder(String runtimeEdgeId, Coder coder) Register a coder for runtime edge.
static long	DataUtil.serializePartition(Coder coder, NonSerializedPartition nonSerializedPartition, ByteArrayOutputStream bytesOutputStream) Serializes the elements in a non-serialized partition into an output stream.

Constructors in edu.snu.coral.runtime.executor.data with parameters of type Coder

Constructor and Description
InputStreamIterator(InputStream inputStream, Coder<T> coder) Construct Iterator from InputStream and Coder.
InputStreamIterator(InputStream inputStream, Coder<T> coder, long limit) Construct Iterator from InputStream and Coder.

Uses of Coder in edu.snu.coral.runtime.executor.data.block

Constructors in edu.snu.coral.runtime.executor.data.block with parameters of type Coder

Constructor and Description
FileBlock(Coder coder, String filePath, FileMetadata<K> metadata) Constructor.
NonSerializedMemoryBlock(Coder coder) Constructor.
SerializedMemoryBlock(Coder coder) Constructor.

Uses of Coder in edu.snu.coral.runtime.executor.data.stores

Methods in edu.snu.coral.runtime.executor.data.stores that return Coder

Modifier and Type	Method and Description
Coder	AbstractBlockStore.getCoderFromWorker(String blockId) Gets data coder for a block from the CoderManager.