
About
複雑なデータ問題を解決することに情熱を注いでいます。日本最大の通信会社でソフトウェアおよびデータエンジニアとして、データプラットフォームを開発しました。また、文化や言語の壁についても学びました。この経験により、優れた技術力、コミュニケーション能力、そして複数のステークホルダーと協力する能力を身につけました。データ移行、異常検知、データ可視化、データウェアハウス設計、機械学習モデルの開発、MLOps、ETLなどのデータプロジェクトに取り組んできました。
職歴 💼#
Kraken Technologies#
Senior Data Engineer
- 日本における唯一のエンジニアとして、プロジェクトマネジメント、要件定義、顧客対応・コミュニケーションを担当し、さらに機能開発まで自ら実施。デリバリーとエンジニアリングの両方の役割を遂行。
- Slackアラートをトリガーに、PagerDuty、Datadog、Databricksのジョブログを自律的に調査し、根本原因を診断してdbtモデルの改善策(インクリメンタルマテリアライゼーションへの切り替え、パーティショニング戦略の改善、不足しているデータ品質テストの追加など)を提案するアラートトリアージAIエージェント(Claude、LangChain)を構築。月次アラート件数を30%削減し、平均解決時間(MTTR)を週あたり約7〜9時間短縮。オンコールチームとアラートメトリクスで効果を検証。
- チーム統合に伴うdbtモデルおよびデータ資産の環境間移行のため、マルチエージェントシステムを設計。DatabricksおよびAirflowのネイティブコネクタを備えたClaudeを移行実行エージェントとして使用し、カスタムツールコール(行数比較、スキーマ比較、パーティション単位の比較、dbtデータ品質テスト検証)を備えた独立した照合エージェントをDatabricks APIで構築して、移行元と移行先環境間の移行正当性を検証。
- Azure Cloud、Snowflake、Databricksにまたがる顧客向けデータ共有機能を開発し、APACクライアント向けにデータプラットフォームの対応クラウドプロバイダーを拡大。
- 顧客のデータチームと連携し、日本語力と文化理解を活かして新技術やKrakenの製品への移行を支援。
- オンコールローテーションに参加して時間外のアラート対応を担当する傍ら、dbtのデータ品質テスト、DAGエラー、鮮度チェックなどの根本原因を修正し、繰り返し発生するアラートノイズを削減。
- インクリメンタル取り込みモデルへの移行によりdbtパイプラインのパフォーマンスを最適化し、処理時間とコンピュートコストを削減。
Tech Stack

Slalom Build#
Senior Data Engineer
不動産クライアント向けRAG(検索拡張生成)チャットボット
- 不動産・プロパティ業界のクライアント向けに、Azure OpenAIのチャットアプリクイックスタートを初期PoC(概念実証)の出発点とし、Azure AI Searchでカスタムドキュメントチャンキング・インデキシングパイプラインを開発してGPT-3.5と連携させ、社内ナレッジに基づくチャットサービスを構築。
- 顧客チームがナレッジベースから作成したグラウンドトゥルースデータセットを用いてシステムを評価。正解ソース文書に対する検索精度を測定するとともに、LLM-as-judgeを用いて生成回答の品質を人間が作成した回答要約と比較してスコアリング。
- CI/CDとインフラのデプロイメントにおけるベストプラクティスを導入。
食品小売クライアント向け予測モデルのSnowflakeへの移行
- AWS SageMakerからSnowflakeネイティブ技術(Snowflakeのモデルレジストリを含む)へ、予測モデルのソースコードとモデルアーティファクトをPythonとSnowparkを用いて移行。
- 特徴量エンジニアリングをSnowpark DataFrame処理に移行し、Snowflakeウェアハウスを適切なサイズに調整し、中間テーブルを永続化して再計算を回避することで、MLパイプラインの実行時間を2時間から30分に短縮。
- ラグ・リード特徴量と季節性シグナルを設計し、マーケティングデータとイベントデータをモデルに統合することで、予測精度を82%から87%に改善。
- GitHubによるコードレビュー、GitHub ActionsによるCI/CD、実験管理をデータサイエンスチームに導入し、開発ワークフローと生産性を改善。
- テックリードとして、週次マイルストーンの設定、技術的方向性の策定、および顧客との要件収集や調整をリード。
産業・IoTテクノロジークライアント向けSQLServerからSnowflakeへの移行
- 13TBの顧客データをSnowflakeに効率的に移行。Airflowを活用してジョブオーケストレーションを合理化し、シームレスなデータ移行を実現。
- BCPを用いてデータをエクスポートし、Snowflakeステージのファイル形式、圧縮、バッチサイズ、並列ロードを調整してデータの取り込みと保存を高速化。
- AWS S3を統合してセキュアでスケーラブルなデータ転送を実現し、移行プロセスにおけるデータの整合性とアクセシビリティを確保。
- 増加分のみのデータコピーと動的データパイプラインのアプローチを通じてSQL Serverの変更をSnowflakeに継続的に同期されるためのシステムを実装。このリアルタイムのデータ可用性により、分析機能とレポーティングの精度が向上した。
Tech Stack

NTT Communications & Docomo Business#
Software Engineer (Data)
Data Engineering
- 様々な社内部門からのデータを収集・分析するデータ分析プラットフォームの開発と保守に貢献しました。プラットフォームのコアコンポーネントのシステムアーキテクチャを設計しました。これには、コンピュートSQLエンジンTrino、ストレージHDFS、認証ワークフロー、およびHadoopエコシステムが含まれます。
- データ分析チームと協力し、データを取得するためのクエリをチューニングし、基盤となる物理スキーマを改善することで、BIダッシュボードのパフォーマンスを向上させました。
- Apache KafkaからHDFSへネットワークトラフィックフローデータを取り込むためのデータパイプラインをPysparkを使用して開発しました。このパイプラインは秒間100万レコード以上を処理し、DDoS攻撃を緩和するためのリアルタイム異常検出に使用されました。
- SQLエンジンTrinoをBIツール、認証システム、データウェアハウスツールなど、他の社内データプラットフォームコンポーネントと統合しました。Javaを使用してTrinoのためのカスタムコネクターを開発し、オープンソースコミュニティに貢献しました。
- Java、Docker、JavaScriptを使用してYouTube再生統計データ収集ツールを開発し、1000ノード以上からYouTube再生のランタイム統計を収集して、QUICプロトコルとHTTPによるインターネットのエンドユーザー品質体験を分析・比較しました。Pythonのデータ可視化ツールplotlyを使用して、1000ノード以上から収集・分析したデータをもとに、2018年ギリシャで開催されたACM CoNEXTで研究成果を発表しました。
Software Engineering
- ReactJSを使用してデータカタログメタデータプラットフォームを開発し、日本語テキストの高度な検索、テーブル検索、スキーマ情報、および10以上の異なる社内システムおよびツールからのメタデータなどの機能を提供することで、チームの生産性を向上させました。
- DeepL API、JavaScript、およびNode.jsを使用して、オープンソースのマークダウンドキュメンテーションツール「CodiMD」に、日英および英日翻訳機能と日本語の漢字に対するふりがな(平仮名での読み)を開発しました。この機能は、日本語を話さないエンジニアと日本人エンジニア間のコミュニケーションと協力を強化しました。
- 2021年に開催されたTrino Japan Virtual Meetupで、NTTコミュニケーションズのTrino使用状況とアーキテクチャ設計について発表しました。
- 新しいチームメンバーをトレーニングし、データプラットフォームの全体的なアーキテクチャを理解するのを助けました。役立つチュートリアルやガイドを作成し、チームの生産性を向上させました。
Tech Stack

Persistent Systems#
プロジェクト 🚀#
AI プロジェクト#
- 単位変換タスクにおける段階的な推論能力を17億パラメータのLLMに学習させるため、Chain-of-Thoughtによるロールアウトと棄却サンプリングを用いた強化学習ファインチューニング(RFT)パイプラインを構築し、通常の教師ありファインチューニングを上回る精度を達成。
- メモリ制約のあるハードウェア上でも大規模モデルのファインチューニングと推論を可能にするため、LoRA、QLoRA、4bit量子化をスクラッチで実装し、精度低下を0.2%未満に抑えながらメモリフットプリントを約7分の1に削減。
- 6種類以上のLLMにおける文化的・言語的バイアスを監査するため、英語と日本語の医学入試問題に対する応答品質(トーン、推論、文脈適切性)を比較するLLM-as-judge評価パイプラインを構築し、1,000件以上の応答を分析。
- SQuAD質問応答モデルの精度向上のため、モデルの失敗パターンを対象としたパラフレーズ済み訓練質問を生成するLLM駆動の合成データ拡張パイプラインを設計し、再学習後のF1スコアを約2ポイント改善。
オープンソース貢献#
Apache Ranger
- Presto の名称変更後、Trino へのコードベースの移行を実施しました。
- Java Logback フレームワークを追加してログ機構を改善し、Java コードベースを JDK17 に移行しました。
Trino (旧 PrestoSQL)
- Trino のドキュメント「セキュリティ」セクションを改善し、構造化されたレイアウトを作成し、言語をリファクタリングしました。活発な Trino コミュニティからのフィードバックを収集し、重要なドキュメントセクションを追加するためのイニシアチブを取りました。
trino-python-client用の JWT 認証機能を開発し、ドキュメントを追加しました。- Trino の Slack コミュニティメンバーを積極的に支援し、トラブルシューティングやデバッグ、アイデアの共有を行いました。
- Trino CLI に対して、履歴に基づいて SQL コマンドを提案する自動補完機能を開発しました。
- Apache RangerとTrinoの統合というタイトルで、世界中の150人以上のデータエンジニアに役立ったチュートリアルを発表しました。
Apache Airflow
- Airflow の接続を介して Trino プロバイダーにセッションプロパティを設定できる機能を追加しました。
- Airflow の接続を介して Trino プロバイダーにクライアントタグを設定できる機能を追加しました。これにより、Airflow を通じて実行される各 Trino クエリに追加のメタデータを追加できます。
認定資格 🏆#
学歴 🎓#
University of Texas at Austin
リモート
Master of Artificial Intelligence
Vishwakarma Institute of Technology
プネ, インド
Bachelor of Technology Computer Engineering
ここに掲載する記事はまだありません。



