FLiNK подсчета строк таблицы с одной и той же записи

Question

У меня есть таблица с различными записями в столбцах (но я не знаю, все из них)

table:  
column1 | column2 
    x1 | y1 
    x1 | y2 
    x2 | y2 
    x3 | y1 
    x3 | y2 

Теперь я хочу получить список или словарь, где все записей первого столбца Количество:

dict = (x1:2, x2:1, x3:2) 

Я пробовал:

table = env.readCsvFile(tablepath).as('column1, 'column2) 
var content = table.select('column1) 
content.count() 

И я пытался использовать слово-граф пример link, но для этого нужен массив строк? так

Wordcount(content) or Wordcount(content.toString()) 

не работает.

Answer 1

Если вы хотите иметь счетчик для каждого значения в column1 вам нужно сгруппировать по column1 и посчитайте:

table = env.readCsvFile(tablepath).as('column1, 'column2) 
var content = table.groupBy('column1').select('column1.count) 

вход в WordCount указывает файл ввода и вывода или данных (он ожидает две строки --- или нет, чтобы использовать данные примера в памяти и распечатать результат до stdout). Параметры, а не данные, подлежащие обработке, хотя.