å··ã§çŸ¥ã£ãŸEmbulkプラグイン開発ノウãƒã‚¦(Javaç·¨) - Qiita
List<String> columnNames = task.getColumns(); ImmutableList.Builder<Column> builder = ImmutableList.builder(); int i = 0; for (String columnName : columnNames) { for (Column inputColumn: inputSchema.getColumns()) { if (inputColumn.getName().equals(columnName)) { Column outputColumn = new Column(i++, columnName, inputColumn.getType()); builder.add(outputColumn); break; } } } Schema outputSchema = n
並列データ転é€ãƒ„ール『Embulkã€ãƒªãƒªãƒ¼ã‚¹ï¼ - Blog by Sadayuki Furuhashi
ã“ã‚“ã«ã¡ã¯ã€‚å¤æ©‹ã§ã™ã€‚ 先日ã®*1 データ転é€ãƒŸãƒ‰ãƒ«ã‚¦ã‚§ã‚¢å‹‰å¼·ä¼šã§ã€æ–°ã—ã„オープンソースツール Embulk をリリースã—ã¾ã—ãŸã€‚ Embulk, an open-source plugin-based parallel bulk data loader from Sadayuki Furuhashi Embulk ã¯ã€ãƒªã‚¢ãƒ«ã‚¿ã‚¤ãƒ ãªãƒã‚°åŽé›†ã§ã¯å¸¸è˜ã¨ãªã£ãŸ fluentd ã®ãƒãƒƒãƒç‰ˆã®ã‚ˆã†ãªãƒ„ールã§ã€ãƒ•ã‚¡ã‚¤ãƒ«ã‚„データベースã‹ã‚‰ãƒ‡ãƒ¼ã‚¿ã‚’å¸ã„出ã—ã€åˆ¥ã®ã‚¹ãƒˆãƒ¬ãƒ¼ã‚¸ã‚„データベースã«ãƒãƒ¼ãƒ‰ã™ã‚‹ãŸã‚ã®ã‚³ãƒ³ãƒ‘クトãªãƒ„ールã§ã™ã€‚ fluentd ã¨åŒæ§˜ã«ãƒ—ラグイン型ã®ã‚¢ãƒ¼ã‚テクãƒãƒ£ã‚’採用 ã—ã¦ã„ã‚‹ãŸã‚ã€Rubyã‚„Javaã§ç°¡å˜ãªã‚³ãƒ¼ãƒ‰ã‚’書ãã“ã¨ã§ã€æ§˜ã€…ãªãƒ•ã‚¡ã‚¤ãƒ«ãƒ•ã‚©ãƒ¼ãƒžãƒƒãƒˆã‚„ストレージã«å¯¾å¿œã™ã‚‹ã“ã¨ãŒã§ãã¾ã™ã€‚一方㧠fluentd ã¨ã¯ç•°ãªã‚Šã€é«˜é€Ÿæ€§ã‚„トランザクション制御ã€ã‚¹ã‚ーマを使ã£ãŸãƒ‡ãƒ¼ã‚¿ã®ãƒãƒª
1
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
処ç†ã‚’実行ä¸ã§ã™
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
{{#tags}}- {{label}}
{{/tags}}