Constructor and Description |
---|
AccMode() |
Modifier and Type | Method and Description |
---|---|
static scala.Enumeration.Value |
Acc()
An operator in
Acc mode emits change messages as
CRow which encode a pair of (Boolean, Row). |
static scala.Enumeration.Value |
AccRetract()
* An operator in
AccRetract mode emits change messages as
CRow which encode a pair of (Boolean, Row). |
static scala.Enumeration.Value |
apply(int x) |
static int |
maxId() |
protected static void |
nextId_$eq(int x$1) |
protected static int |
nextId() |
protected static void |
nextName_$eq(scala.collection.Iterator<String> x$1) |
protected static scala.collection.Iterator<String> |
nextName() |
protected static Object |
readResolve() |
static String |
toString() |
protected static scala.Enumeration.Value |
Value() |
protected static scala.Enumeration.Value |
Value(int i) |
protected static scala.Enumeration.Value |
Value(int i,
String name) |
protected static scala.Enumeration.Value |
Value(String name) |
static scala.Enumeration.ValueSet |
values() |
static scala.Enumeration.Value |
withName(String s) |
public static scala.Enumeration.Value Acc()
Acc
mode emits change messages as
CRow
which encode a pair of (Boolean, Row).
An operator in Acc
mode may only produce update and delete messages, if the table has
a unique key and all key attributes are contained in the Row.
Changes are encoded as follows: - insert: (true, NewRow) - update: (true, NewRow) // the Row includes the full unique key to identify the row to update - delete: (false, OldRow) // the Row includes the full unique key to idenify the row to delete
public static scala.Enumeration.Value AccRetract()
AccRetract
mode emits change messages as
CRow
which encode a pair of (Boolean, Row).
Changes are encoded as follows: - insert: (true, NewRow) - update: (false, OldRow), (true, NewRow) // updates are encoded in two messages! - delete: (false, OldRow)
protected static Object readResolve()
public static String toString()
public static scala.Enumeration.ValueSet values()
protected static int nextId()
protected static void nextId_$eq(int x$1)
protected static scala.collection.Iterator<String> nextName()
protected static void nextName_$eq(scala.collection.Iterator<String> x$1)
public static final int maxId()
public static final scala.Enumeration.Value apply(int x)
public static final scala.Enumeration.Value withName(String s)
protected static final scala.Enumeration.Value Value()
protected static final scala.Enumeration.Value Value(int i)
protected static final scala.Enumeration.Value Value(String name)
protected static final scala.Enumeration.Value Value(int i, String name)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.