Package | Description |
---|---|
edu.snu.coral.common | |
edu.snu.coral.compiler.frontend.beam.coder | |
edu.snu.coral.examples.beam | |
edu.snu.coral.runtime.common.eventhandler | |
edu.snu.coral.runtime.master.scheduler |
Modifier and Type | Method and Description |
---|---|
static <A,B> Pair<A,B> |
Pair.of(A left,
B right)
Static initializer of the Pair class.
|
Modifier and Type | Method and Description |
---|---|
Pair<A,B> |
PairCoder.decode(InputStream inStream) |
Modifier and Type | Method and Description |
---|---|
void |
PairCoder.encode(Pair<A,B> pair,
OutputStream outStream) |
boolean |
PairCoder.isRegisterByteSizeObserverCheap(Pair<A,B> pair)
Returns whether both leftCoder and rightCoder are considered not expensive.
|
void |
PairCoder.registerByteSizeObserver(Pair<A,B> pair,
org.apache.beam.sdk.util.common.ElementByteSizeObserver observer)
Notifies ElementByteSizeObserver about the byte size of the
encoded value using this coder.
|
Object |
PairCoder.structuralValue(Pair<A,B> pair) |
Modifier and Type | Method and Description |
---|---|
Pair<List<Integer>,List<Double>> |
AlternatingLeastSquare.TrainingDataCombiner.extractOutput(List<Pair<List<Integer>,List<Double>>> accumulator) |
Modifier and Type | Method and Description |
---|---|
List<Pair<List<Integer>,List<Double>>> |
AlternatingLeastSquare.TrainingDataCombiner.addInput(List<Pair<List<Integer>,List<Double>>> accumulator,
Pair<List<Integer>,List<Double>> value) |
List<Pair<List<Integer>,List<Double>>> |
AlternatingLeastSquare.TrainingDataCombiner.createAccumulator() |
List<Pair<List<Integer>,List<Double>>> |
AlternatingLeastSquare.TrainingDataCombiner.mergeAccumulators(Iterable<List<Pair<List<Integer>,List<Double>>>> accumulators) |
Modifier and Type | Method and Description |
---|---|
List<Pair<List<Integer>,List<Double>>> |
AlternatingLeastSquare.TrainingDataCombiner.addInput(List<Pair<List<Integer>,List<Double>>> accumulator,
Pair<List<Integer>,List<Double>> value) |
Modifier and Type | Method and Description |
---|---|
List<Pair<List<Integer>,List<Double>>> |
AlternatingLeastSquare.TrainingDataCombiner.addInput(List<Pair<List<Integer>,List<Double>>> accumulator,
Pair<List<Integer>,List<Double>> value) |
Pair<List<Integer>,List<Double>> |
AlternatingLeastSquare.TrainingDataCombiner.extractOutput(List<Pair<List<Integer>,List<Double>>> accumulator) |
List<Pair<List<Integer>,List<Double>>> |
AlternatingLeastSquare.TrainingDataCombiner.mergeAccumulators(Iterable<List<Pair<List<Integer>,List<Double>>>> accumulators) |
Modifier and Type | Method and Description |
---|---|
Pair<String,String> |
UpdatePhysicalPlanEvent.getTaskInfo() |
Pair<String,String> |
DynamicOptimizationEvent.getTaskInfo() |
Constructor and Description |
---|
DynamicOptimizationEvent(PhysicalPlan physicalPlan,
MetricCollectionBarrierVertex metricCollectionBarrierVertex,
Pair<String,String> taskInfo)
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
Scheduler.updateJob(String jobId,
PhysicalPlan newPhysicalPlan,
Pair<String,String> taskInfo)
Receives and updates the scheduler with a new physical plan for a job.
|
void |
BatchSingleJobScheduler.updateJob(String jobId,
PhysicalPlan newPhysicalPlan,
Pair<String,String> taskInfo) |
Copyright © 2018. All rights reserved.