public class WindowJoin extends Object
Modifier and Type | Class and Description |
---|---|
static class |
WindowJoin.Grade |
static class |
WindowJoin.Grade$ |
static class |
WindowJoin.Person |
static class |
WindowJoin.Person$ |
static class |
WindowJoin.Salary |
static class |
WindowJoin.Salary$ |
Constructor and Description |
---|
WindowJoin() |
Modifier and Type | Method and Description |
---|---|
static int |
gradeCount() |
static scala.collection.immutable.Stream<scala.Tuple3<Object,String,Object>> |
gradeStream() |
static void |
main(String[] args) |
static String[] |
names() |
static scala.Tuple3<Object,String,Object> |
parseMap(String line) |
static int |
salaryMax() |
static scala.collection.immutable.Stream<scala.Tuple3<Object,String,Object>> |
salaryStream() |
static int |
sleepInterval() |
public static void main(String[] args)
public static String[] names()
public static int gradeCount()
public static int salaryMax()
public static int sleepInterval()
public static scala.collection.immutable.Stream<scala.Tuple3<Object,String,Object>> gradeStream()
public static scala.collection.immutable.Stream<scala.Tuple3<Object,String,Object>> salaryStream()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.