co.cask.cdap.etl.mock.spark

Class Window

java.lang.Object

co.cask.cdap.etl.api.streaming.Windower

co.cask.cdap.etl.mock.spark.Window

All Implemented Interfaces:

PipelineConfigurable, Serializable

public class Window
extends Windower

Window plugin.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Window.Conf Config for window plugin.

Field Summary

Fields

Modifier and Type	Field and Description
static PluginClass	PLUGIN_CLASS

Fields inherited from class co.cask.cdap.etl.api.streaming.Windower

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
Window(Window.Conf conf)

Method Summary

Modifier and Type	Method and Description
static ETLPlugin	getPlugin(long width, long slideInterval)
long	getSlideInterval()
long	getWidth()

Methods inherited from class co.cask.cdap.etl.api.streaming.Windower

configurePipeline

Methods inherited from class java.lang.Object

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

Field Detail

PLUGIN_CLASS

public static final PluginClass PLUGIN_CLASS

Constructor Detail

Window

public Window(Window.Conf conf)

Method Detail

getWidth

public long getWidth()

Specified by:

getWidth in class Windower

getSlideInterval

public long getSlideInterval()

Specified by:

getSlideInterval in class Windower

getPlugin

public static ETLPlugin getPlugin(long width,
                                  long slideInterval)
                           throws IOException

Throws:

IOException