ืืคื ื ืืื ืื, ืขืืื ื ืืคื ื ืืฉืืื ืฉื ืืืืจืช ืืื ETL ืืขืืืื ืขื Big Data. ืคืชืจืื Informatica BDM ืฉื ืขืฉื ืื ืฉืืืืฉ ืืขืืจ ืื ืืชืืื ืื ื ืืืื ืคืื ืงืฆืืื ืืืืช ืืืืืืช. ืืฉืืืืฉ ืื ืฆืืืฆื ืืืกืืจืช ืืืคืขืืช ืคืงืืืืช ืฉืืืื ืฉื ื ืืฆืืฅ. ืื ืืื ืืจืื ืื ืืืืื ืืฉืืง ืฉืืื ืืกืืืืื, ืืืืคื ืขืงืจืื ื, ืืขืืื ืขื ื ืคื ืื ืชืื ืื ืฉืื ื ืขืืกืงืื ืื ืืื ืืื. ืืกืืคื ืฉื ืืืจ ืืืจื ื ืืื ืืื ืืืื. ืืืืื ืืืืืืช ืคืืืืื, ืืืืฆืจ ืืจืื ืืืืจืืช ืขืืืื ื ืชืื ืื ืืืืื ืืืื. ืืื ืืืขื ืืืืข ืขื Ab Initio ืืจืืกืืช, ืื ืืืืื ื ืืืืจ ืขื ืื ืืกืืื ืฉืื ื ื-Habrรฉ.
ื- Ab Initio ืืฉ ืืจืื ืืจื ืกืคืืจืืฆืืืช ืงืืืกืืืช ืืืืฆืืืช ืืืคื, ืฉืืช ืืงืื ืฉืืื ื ืืชื ืืืจืืื ืืืืฆืขืืช ืฉืคืช PDL ืืฉืื. ืขืืืจ ืขืกืง ืงืื, ืืื ืื ืจืื ืืื ืจื ืขืืฆืื ืืื ืืืื ืืืืื, ืืจืื ืืืืืืืช ืฉืื ืขืฉืืืืช ืืืืืช ืืงืจืืช ืืื ืืฉืืืืฉ. ืืื ืื ืงื ื ืืืืื ืฉืื ืงืจืื ืืื ืฉื ืกืืจืื, ืื Ab Initio ืขืฉืื ืืืืืช ืืขื ืืื ืืืชื.
ืื ืขืืืจ ืืขืกืง ืืฆืืืจ ืืืข ืืืืืื ืืืคืชื ืืงืืกืืกืื, ืืืืคืชื ืืฉืคืจ ืืช ืืืฉืืจืื ื-ETL, ืืฉืคืจ ืืช ืืืืข ืฉืื ืืืขืืคืช, ืืกืคืง ืืืืื ืืช ืืฉืืื ืืฉืคืช PDL, ื ืืชื ืชืืื ื ืืืืืืืืช ืฉื ืชืืืืื ืืืขืื ื ืืืคืฉื ืคืืชืื ืืฉื ืฉืคืข ืืจืืืืื ืืคืื ืงืฆืืื ืืืื.
ืืคืืกื ืื ืืืืจ ืขื ืืืืืืืช ืฉื Ab Initio ืืืกืคืง ืืืคืืื ืื ืืฉืืืืชืืื ืฉื ืขืืืืชื ืขื Hive ื-GreenPlum.
- ืชืืืืจ ืฉื ืืกืืจืช MDW ืืขืืืื ืขื ืืืชืืื ืืืืฉืืช ืฉืื ืขืืืจ GreenPlum
- ืืฉืืืืช ืืืฆืืขืื ืฉื Ab Initio ืืื Hive ื-GreenPlum
- ืขืืืื Ab Initio ืขื GreenPlum ืืืฆื ืงืจืื ืืืื ืืืช
ืืคืื ืงืฆืืื ืืืืช ืฉื ืืืฆืจ ืื ืจืืื ืืืื ืืืืจืฉืช ืืื ืจื ืืืืืื. ืขื ืืืช, ืขื ืืืฉืืจื ืืขืืืื ืื ืืื ืื ืืืืืจืืช ืืืืฆืืขืื ืื ืืื ืืช, ืืชืืฆืืืช ืฉื ืขืืืื ืื ืชืื ืื ืืจืฉืืืืช ืืืื. ืฉืืืืฉ ื- Ab Initio ืขืืืจ ืืคืชื ืืืื ืืกืคืง ืืืืื ืืขื ืืื ืช. ืืื ืืืืืฉ ืืืฉ ืืคืืชืื ETL, ืืืืื ืืื ืกืืืื ืืืืชืืช ืืคืืชืื ืืืจืืืช ืืฉืคื ืืืืืช ืกืงืจืืคื.
ืขืกืงืื ืืคืชืืื ืืช ืืืขืจืืืช ืืืงืืืืืืืช ืฉืืื ืืืืื ืืื ืฉืืืืฉื ืืืชืจ ืืชืืื. ืขื Ab Initio, ืชืืื ืืฆืืืจ ืืืข ืขื ืืขืกืง ืื ืืืื ืฉืื ืืืืฉืชืืฉ ืืืืข ืื ืืื ืืืจืืื ืขืกืงืื ืืฉื ืื ืืืคืชืื ืขืกืงืื ืืืฉืื. ืืืืคืืช ืืื ืืื ืืืื ืืืืืืช ืกืืืืืช ืคืืชืื ืืืืชื Informatica BDM ืืกืืืืืช ืคืืชืื ืื ืืืืชืืืช Apache Spark.
ืชืืืืจ ืฉื ืื ืืื ืืืื
Ab Initio, ืืื ืืื ETL ืืืจืื, ืืื ืืืกืฃ ืฉื ืืืฆืจืื.
Ab Initio GDE (ืกืืืื ืืคืืชืื ืืจืคื) ืืื ืกืืืื ืขืืืจ ืืืคืชื ืื ืืื ืืืืืจ ืืจื ืกืคืืจืืฆืืืช ื ืชืื ืื ืืืืืจ ืืืชื ืขื ืืจืืืืช ื ืชืื ืื ืืฆืืจืช ืืฆืื. ืืืงืจื ืื, ืงืืืฆื ืืื ืฉื ืืจื ืกืคืืจืืฆืืืช ื ืงืจืืช ืืจืฃ:
ืืืืืจื ืืงืื ืืืคืื ืฉื ืจืืืืื ืคืื ืงืฆืืื ืืืื ืื ืืฆืืืืช ืืืืืืื ืฉืืืช ืืืืืฉืืื ืืชืื ืืจื ืกืคืืจืืฆืืืช. ืืกืคืจ ืืจืคืื ืืืืืืจืื ืืืจืืืืช ืืฆืืจื ืฉื ืืฆืื ืืกืืจ ืืืฆืืขื ื ืงืจืืื ืชืืื ืืช.
ืืฉื ื ืืื ืืืืช ืจืืืืื ืคืื ืงืฆืืื ืืืื, ืืื ืืจืื. ืจืืื ืืื ืืชืืืื ืืืื. ืืืืืืืช ืฉื ืืจื ืกืคืืจืืฆืืืช ืงืืืกืืืช ื- Ab Initio ืจืืืืช ืืืชืจ ืืืฉืจ ืืืื ETL ืืืจืื. ืืืืืื, ื- Join ืืฉ ืืฆืืืืช ืืจืืืืช. ืื ืืกืฃ ืืชืืฆืื ืฉื ืืืืืจ ืืขืจืื ื ืชืื ืื, ื ืืชื ืืงืื ืจืฉืืืืช ืคืื ืฉื ืืขืจืื ื ืชืื ืื ืฉื ืงืื ืฉืื ื ืืชื ืืื ืืืืจ ืืช ืืืคืชืืืช ืฉืืื. ืืชื ืืืื ืื ืืงืื ืืืืืช, ืฉืืืืืช ืืืืื ืฉื ืคืขืืืช ืืืจื ืกืคืืจืืฆืื, ืืืชื ื ืืชื ืืงืจืื ืืืืชื ืขืืืื ืืื ืงืืืฅ ืืงืกื ืืืขืื ืืืชื ืขื ืืจื ืกืคืืจืืฆืืืช ืืืจืืช:
ืื, ืืืฉื, ืืชื ืืืื ืืืืฉ ืืงืื ื ืชืื ืื ืืฆืืจื ืฉื ืืืื ืืืงืจืื ืืื ื ื ืชืื ืื ืืืืชื ืขืืืื.
ืืฉ ืืจื ืกืคืืจืืฆืืืช ืืงืืจืืืช. ืืืืืื, ืืฉืื ืื ืืกืจืืงื ืืฉ ืคืื ืงืฆืืื ืืืืช ืืืื ืืคืื ืงืฆืืืช ืื ืืืืืืช. ืืฉ ืืจื ืกืคืืจืืฆืืืช ืขื ืฉืืืช ืฉืืกืืืจืื ืืช ืขืฆืื: ืฆืืจ ื ืชืื ืื, ืงืจื ืืงืกื, ืื ืจืื, ืืืื ืืชืื ืงืืืฆืืช, ืืคืขื ืชืืื ืืช, ืืคืขื SQL, ืืฆืืจืฃ ืขื DB ืืื'. ืืจืคืื ืืืืืื ืืืฉืชืืฉ ืืคืจืืืจืื ืฉื ืืื ืจืืฆื, ืืืื ืืคืฉืจืืช ืืืขืืืจ ืคืจืืืจืื ื ืื ืื ืืขืจืืช ืืืคืขืื. ืงืืฆืื ืขื ืงืืืฆื ืืืื ื ืฉื ืคืจืืืจืื ืืืืขืืจืื ืืืจืฃ ื ืงืจืืื ืขืจืืืช ืคืจืืืจืื (psets).
ืืฆืคืื, ื-Ab Initio GDE ืืฉ ืืืืจ ืืฉืื ืืฉื EME (Enterprise Meta Environment). ืืืคืชืืื ืืฉ ืืืืื ืืช ืืขืืื ืขื ืืจืกืืืช ืืงืืืืืช ืฉื ืงืื ืืืืืืง ืืช ืืคืืชืืืื ืฉืืื ืืชืื ืืืืืจ ืืืจืืื.
ื ืืชื, ืืืืื ืืืืฆืืข ืื ืืืืจ ืืืฆืืข ืืืจืฃ, ืืืืืฅ ืขื ืื ืืจืืื ืืืืืจืช ืืช ืืืจื ืกืคืืจืืฆืื ืืืืกืชืื ืขื ืื ืชืื ืื ืฉืขืืจื ืืื ืืืจื ืกืคืืจืืฆืืืช ืืืื:
ืืคืฉืจ ืื ืืืืืฅ ืขื ืื ืืจื ืืืจืืืช ืคืจืื ืืขืงื - ืืืื ืืงืืืืืช ืขืืื ืืืจื ืกืคืืจืืฆืื, ืืื ืงืืืื ืืืืืืื ื ืืขื ื ืืืืื ืืืืงืืืืืช:
ืืคืฉืจ ืืืืง ืืช ืืืฆืืข ืืืจืฃ ืืฉืืืื ืืืกืื ืฉืฆืจืื ืืืฆืข ืงืืื ืืื ืืจื ืกืคืืจืืฆืืืช (ืืฉืื ืืืคืก), ืืืืืช ืืฉืื ืืจืืฉืื, ืืืืืช ืืฉืื ืืฉื ื ืืื'.
ืขืืืจ ืื ืืจื ืกืคืืจืืฆืื, ืืชื ืืืื ืืืืืจ ืื ืฉื ืงืจื ืคืจืืกื (ืืืื ืืื ืชืชืืฆืข): ืืื ืืงืืืืื ืื ืืฉืจืฉืืจืื ืืงืืืืื, ืฉื ืืชื ืืฆืืื ืืช ืืกืคืจื. ืืื ืขื ืืืช, ื ืืชื ืืืงื ืงืืฆืื ืืื ืืื ืฉ-Ab Initio ืืืฆืจ ืืืฉืจ ืืจื ืกืคืืจืืฆืืืช ืคืืขืืืช ืื ืืืขืจืืช ืงืืฆื ืืฉืจืช ืืื ื-HDFS.
ืืื ืืจื ืกืคืืจืืฆืื, ืืืชืืกืก ืขื ืชืื ืืช ืืจืืจืช ืืืืื, ืืชื ืืืื ืืืฆืืจ ืกืงืจืืคื ืืฉืื ื-PDL, ืฉืืื ืงืฆืช ืืื ืืขืืคืช.
ืขื PDL ืืชื ืืืื ืืืจืืื ืืช ืืคืื ืงืฆืืื ืืืืช ืฉื ืืจื ืกืคืืจืืฆืืืช, ืืืคืจื, ืืชื ืืืื ืืืฆืืจ ืืืืคื ืืื ืื (ืืืื ืจืืฆื) ืงืืขื ืงืื ืฉืจืืจืืชืืื ืืืชืื ืืคืจืืืจืื ืฉื ืืื ืจืืฆื.
ื- Ab Initio ืืฉ ืื ืืื ืืืจืฆืื ืืคืืชืืช ืขื ืืขืจืืช ืืืคืขืื ืืจื ืืขืืคืช. ืืืืคื ืกืคืฆืืคื, Sberbank ืืฉืชืืฉ ื- linux ksh. ืืชื ืืืื ืืืืืืฃ ืืฉืชื ืื ืขื ืืืขืืคืช ืืืืฉืชืืฉ ืืื ืืคืจืืืจืื ืืจืคืื. ืืชื ืืืื ืืงืจืื ืืืืฆืืข ืืจืคืื ืฉื Ab Initio ืืืงืืืคื ืืื ืื ืืช Ab Initio.
ืื ืืกืฃ ื-Ab Initio GDE, ืืืฆืจืื ืจืืื ื ืืกืคืื ืืืืืื ืืืฉืืื. ืืฉ ืืขืจืืช ืฉืืชืืฃ ืคืขืืื ืืฉืื ืขื ืืขื ื ืืืืงืจื ืืขืจืืช ืืคืขืื. ืืฉื ื ืืจืื ืืงืจื ืฉืื ืืชื ืืืื ืืชืืื ืืื ืืจ ืืจืืืืช ืืืจืื. ืืฉื ื ืืืฆืจืื ืืืืฆืืข ืคืืชืื ืืจืื ืคืจืืืืืืืืช ืืืชืจ ืืื ืฉ-Ab Initio GDE ืืืคืฉืจ.
ืชืืืืจ ืฉื ืืกืืจืช MDW ืืขืืืื ืขื ืืืชืืื ืืืืฉืืช ืฉืื ืขืืืจ GreenPlum
ืืื ืขื ืืืฆืจืื, ืืกืคืง ืืกืคืง ืืช ืืืืฆืจ MDW (Metadata Driven Warehouse), ืฉืืื ืงืืคืืืืจืืืจ ืืจืคืื ืฉื ืืขื ืืกืืืข ืืืฉืืืืช ืืืคืืกืืืช ืฉื ืืืืืืก ืืืกื ื ื ืชืื ืื ืื ืืกืคืืช ื ืชืื ืื.
ืืื ืืืื ืื ืชืื ืืื ื ืชืื ืื ืืืชืืืื ืืืฉืืช (ืกืคืฆืืคืืื ืืคืจืืืงื) ืืืืืืื ืงืื ืืืื ืื ืืืงืืคืกื.
ืืงืื, MDW ืืงืื ืืืื ื ืชืื ืื, ืงืืืฅ ืชืฆืืจื ืืืืืจืช ืืืืืจ ืืืกื ื ืชืื ืื (Oracle, Teradata ืื Hive) ืืขืื ืืื ืืืืจืืช. ืืืืง ืืกืคืฆืืคื ืืคืจืืืงื, ืืืฉื, ืคืืจืก ืืช ืืืืื ืืืกื ื ืชืื ืื. ืืืืง ืืืืฆื ืืืงืืคืกื ืฉื ืืืืฆืจ ืืืืฆืจ ืขืืืจื ืืจืคืื ืืงืืฆื ืชืฆืืจื ืขื ืืื ืืขืื ืช ื ืชืื ืื ืืืืืืืช ืืืื. ืืืงืจื ืื, ืืจืคืื (ื-psets) ื ืืฆืจืื ืขืืืจ ืืกืคืจ ืืฆืืื ืฉื ืืชืืื ืืขืืืื ืืฆืืืจืช ืขื ืขืืืื ืืฉืืืืช.
ืืืงืจืื ืฉื Hive ื-RDBMS, ื ืืฆืจืื ืืจืคืื ืฉืื ืื ืืืชืืื ืืขืืืื ื ื ืชืื ืื ืืฆืืืจืื.
ืืืงืจื ืฉื Hive, ื ืชืื ื ืืืืชื ืื ืื ืกืื ืืืืืจืื ืืจื Ab Initio Join ืขื ืื ืชืื ืื ืฉืืื ืืืืื ืืคื ื ืืขืืืื. ืืขืืืกื ื ืชืื ืื ื-MDW (ืื ื-Hive ืืื ื-RDBMS) ืื ืจืง ืืื ืืกืื ื ืชืื ืื ืืืฉืื ืืืืืชื, ืืื ืื ืกืืืจืื ืืช ืชืงืืคืืช ืืจืืืื ืืืืช ืฉื ืื ืชืื ืื ืฉืืืคืชืืืช ืืจืืฉืืื ืฉืืื ืงืืืื ืืช ืืืืชื. ืื ืืกืฃ, ืขืืื ืืฉืืชื ืืช ืืืืง ืืื ืฉืื ืื ืฉื ืื ืชืื ืื. ืืื ืื ืืืื ืืืืขืฉืืช ืืืืืื ืฉื-Hive ืืื ืคืขืืืืช ืืืืงื ืื ืขืืืื.
ืืืงืจื ืฉื RDBMS, ืืจืคืื ืืขืืืื ื ืชืื ืื ืืฆืืืจ ื ืจืืื ืืืคืืืืืืื ืืืชืจ, ืืืืืื ืฉื-RDBMS ืืฉ ืืืืืืช ืขืืืื ืืืืชืืืช.
ืืืืชื ืฉืืชืงืืื ื ืืขื ืช ืืืืืช ืืื ืืื ืืืกื ืื ืชืื ืื. ืืืืจ ืืื, ืืืืชื ืืืืืจืช ืื ืชืื ืื ืฉืืื ืืืืื ืืคื ื ืืขืืืื. ืืื ื ืขืฉื ืืืืฆืขืืช SQL ืืืืฆืขืืช ืฉืืืืชืช SQL ืฉื ืืฆืจื. ืืืืจ ืืื, ืืืืฆืขืืช ืคืงืืืืช SQL delete+insert, ื ืชืื ืื ืืืฉืื ืืืืืชื ืืืื ืกืื ืืืืืช ืืืขื ืืกืืืจืืช ืชืงืืคืืช ืืจืืืื ืืืืช ืฉื ืื ืชืื ืื ืฉืืืคืชืืืช ืืจืืฉืืื ืฉืืื ืงืืืื ืืช ืืืืชื.
ืืื ืฆืืจื ืืฉืืชื ื ืชืื ืื ืืื ืฉืื ืื.
ืื ืืืขื ื ืืืกืงื ื ืฉืืืงืจื ืฉื Hive, MDW ืฆืจืื ืืืืช ืืฉืืชื ืืช ืื ืืืืื ืื ื-Hive ืืื ืคืื ืงืฆืืืช ืขืืืื. ืืืื ืืืจ ืืื ืืืชืจ ืืืืชืื ืืืืฉ ืืืืืืื ืืช ืื ืชืื ืื ืืืฉืจ ืืขืืืื ืืืืฆื. ืืืงืจื ืฉื RDBMS, ืืืืคื, ืืืฆืจื ืืืืฆืจ ืืฆืื ืฆืืจื ืืืคืงืื ืืช ืืืืืืจ ืืขืืืื ืืืืืืืช ืืฉืืืืฉ ื-SQL.
ืขืืืจ ืคืจืืืงื ื-Sberbank, ืืฆืจื ื ืืืฉืื ืืืฉ ืืฉืืืืฉ ืืืืจ ืฉื ืืืขืื ืืกื ื ืชืื ืื ืขืืืจ GreenPlum. ืื ื ืขืฉื ืขื ืกืื ืืืจืกื ืฉ-MDW ืืืืฆืจืช ืขืืืจ Teradata. ืื ืืื Teradata, ืืื ืืืจืงื, ืฉืืชืงืจื ืืืื ืืื ืืฉืืื ืื, ืื... ืืื ืื ืืขืจืืช MPP. ืฉืืืืช ืืขืืืื, ืืื ืื ืืชืืืืจ, ืฉื Teradata ื-GreenPlum ืืชืืจืจื ืืืืืืช.
ืืืืืืืช ืืืืืืื ืงืจืืืืื ื-MDW ืืื RDBMSs ืฉืื ืื ืื ืืืืงืื. ื-GreenPlum, ืื ืืืื ื-Teradata, ืืขืช ืืฆืืจืช ืืืืืืช ืืชื ืฆืจืื ืืืชืื ืกืขืืฃ
distributed by
Teradata ืืืชื:
delete <table> all
, ืื-GreenPlum ืื ืืืชืืื
delete from <table>
ืืืืจืงื, ืืืืจืืช ืืืคืืืืืืฆืื ืืืชืืื
delete from t where rowid in (<ัะพะตะดะธะฝะตะฝะธะต t ั ะดะตะปััะพะน>)
, ื-Teradata ื-GreenPlum ืืืชืืืช
delete from t where exists (select * from delta where delta.pk=t.pk)
ื ืฆืืื ืื ืฉืืื ืฉ-Ab Initio ืชืขืืื ืขื GreenPlum, ืืื ืฆืืจื ืืืชืงืื ืืช ืืงืื GreenPlum ืืื ืืฆืืชืื ืฉื ืืฉืืื Ab Initio. ืืกืืื ืืื ืืื ืฉืืชืืืจื ื ื-GreenPlum ืื-ืืื ืืช ืืื ืืฆืืชืื ืืืฉืืื ืฉืื ื. ืืืื ืฉืืงืจืืื ื-GreenPlum ืชืืื ืืงืืืื ืืื ืฉืจืฉืืจ ืืงืืื ืฉื Ab Initio ืืงืจื ืืืง ืืฉืื ืืื ืชืื ืื ื-GreenPlum, ืืืื ื ืฆืจืืืื ืืืงื ืงืื ืกืืจืืงืฆืื ืืืืื ืช ื-Ab Initio ืืงืืข "ืืืื" ืฉื ืฉืืืืชืืช SQL
where ABLOCAL()
ืืืงืืืข ืืช ืืขืจื ืฉื ืื ืืื ืื ืขื ืืื ืฆืืื ืงืจืืืช ืืคืจืืืจืื ืืืกื ืื ืชืื ืื ืฉื ืืืจื ืกืคืืจืืฆืื
ablocal_expr=ยซstring_concat("mod(t.", string_filter_out("{$TABLE_KEY}","{}"), ",", (decimal(3))(number_of_partitions()),")=", (decimal(3))(this_partition()))ยป
, ืฉืืชืืืจ ืืืฉืื ืืื
mod(sk,10)=3
, ืืืืืจ ืขืืื ืืื ืืืช ืืช GreenPlum ืขื ืืกื ื ืืคืืจืฉ ืขืืืจ ืื ืืืืฆื. ืขืืืจ ืืกืื ื ืชืื ืื ืืืจืื (Teradata, Oracle), Ab Initio ืืืื ืืืฆืข ืืช ืืืงืืื ืืื ืืืืคื ืืืืืืื.
ืืฉืืืืช ืืืฆืืขืื ืฉื Ab Initio ืืื Hive ื-GreenPlum
Sberbank ืขืจืื ื ืืกืื ืืืฉืืืืช ืืืืฆืืขืื ืฉื ืืจืคืื ืฉื ืืฆืจื ืขื ืืื MDW ืืืืก ื-Hive ืืืืืก ื-GreenPlum. ืืืืง ืืื ืืกืื, ืืืงืจื ืฉื Hive ืืื 5 ืฆืืชืื ืขื ืืืชื ืืฉืืื ืืื Ab Initio, ืืืืงืจื ืฉื GreenPlum ืืื 4 ืฆืืชืื ืขื ืืฉืืื ื ืคืจื. ืึธืึตื. ื-Hive ืืื ืืชืจืื ืืืืจื ืืกืืื ืขื ืคื ื GreenPlum.
ืฉืงืื ื ืฉื ื ืืืืืช ืฉื ืืจืคืื ืฉืืืฆืขืื ืืช ืืืชื ืืฉืืื ืฉื ืขืืืื ื ืชืื ืื ื-Hive ืื-GreenPlum. ืืืงืืื, ืืืฉืงื ืืืจืคืื ืฉื ืืฆืจื ืขื ืืื ืงืืคืืืืจืืืจ MDW:
- ืืขืื ื ืจืืฉืื ืืช + ืขืืืก ืืฆืืืจ ืฉื ื ืชืื ืื ืฉื ืืฆืจื ืืืืคื ืืงืจืื ืืืืื ืฉื Hive
- ืืขืื ื ืจืืฉืื ืืช + ืขืืืก ืืฆืืืจ ืฉื ื ืชืื ืื ืฉื ืืฆืจื ืืืืคื ืืงืจืื ืืืืชื ืืืื ืฉื GreenPlum
ืืฉื ื ืืืงืจืื (Hive ื-GreenPlum) ืื ืืจืืฆื ืืขืืืืช ื-10 ืฉืจืฉืืจืื ืืงืืืืื ืขื ืืืชื ืืฉืืื Ab Initio. Ab Initio ืฉืืจื ื ืชืื ื ืืื ืืื ืืืืฉืืืื ื-HDFS (ืืืื ืืื ืฉื Ab Initio, ื ืขืฉื ืฉืืืืฉ ืืคืจืืกืช MFS ืืืืฆืขืืช HDFS). ืฉืืจื ืืืช ืฉื ื ืชืื ืื ืฉื ืืฆืจื ืืืงืจืื ืชืคืกื 200 ืืชืื ืืฉื ื ืืืงืจืื.
ืืชืืฆืื ืืืืชื ืืื:
ืืืืจืช:
ืืขืื ื ืจืืฉืื ืืช ืืืืืจืช
ื ืืกืคื ืฉืืจืืช
6 000 000
60 000 000
600 000 000
ืืฉื ืืชืืื
ืืืจืืืช ืชืื ืฉื ืืืช
41
203
1 601
ืืขืื ื ืืฆืืืจืช ืืืืืจืช
ืืกืคืจ ืืฉืืจืืช ืืืืื ืืช ื
ืืืืช ืืขื ืืชืืืืช ืื ืืกืื
6 000 000
60 000 000
600 000 000
ืืกืคืจ ืงืืื ืืืืชื ืฉืืืืื ืขืืืื
ืืืืช ืืขื ืืืืื ืื ืืกืื
6 000 000
6 000 000
6 000 000
ืืฉื ืืืื ืืืฆืืืจ
ืืืจืืืช ืชืื ืฉื ืืืช
88
299
2 541
GreenPlum:
ืืขืื ื ืจืืฉืื ืืช ื-GreenPlum
ื ืืกืคื ืฉืืจืืช
6 000 000
60 000 000
600 000 000
ืืฉื ืืชืืื
ืืืจืืืช ืชืื ืฉื ืืืช
72
360
3 631
ืืขืื ื ืืฆืืืจืช ื-GreenPlum
ืืกืคืจ ืืฉืืจืืช ืืืืื ืืช ื
ืืืืช ืืขื ืืชืืืืช ืื ืืกืื
6 000 000
60 000 000
600 000 000
ืืกืคืจ ืงืืื ืืืืชื ืฉืืืืื ืขืืืื
ืืืืช ืืขื ืืืืื ืื ืืกืื
6 000 000
6 000 000
6 000 000
ืืฉื ืืืื ืืืฆืืืจ
ืืืจืืืช ืชืื ืฉื ืืืช
159
199
321
ืื ื ืจืืืื ืฉืืืืจืืช ืืืขืื ื ืืจืืฉืื ืืช ื-Hive ืืื ื-GreenPlum ืชืืืื ืืืืคื ืืื ืืืจื ืืืืืช ืื ืชืื ืื, ืืืืขืืื ืฉื ืืืืจื ืืืื ืืืชืจ, ืืื ืืขื ืืืืจื ืืืชืจ ืขืืืจ Hive ืืืฉืจ ืขืืืจ GreenPlum.
ืืขืื ื ืืฆืืืจืช ืืืืืจืช ืชืืืื ืืืืคื ืืื ืืืจื ืื ืื ืคื ืื ืชืื ืื ืฉื ืืขื ื ืงืืื ืืื ืืืืื ืื ืืืืืช ืืืขื ืืืชืืฉืืช ืื ืืื ืืื ืฉืื ืคื ืืื. ืื ื ืืจื ืืืฆืืจื ืืฉืืชื ืืช ืืืืช ืืืขื ืืืืืืื. ืืฉืืขืืช ืืืืจ ืืื ืฉืืืืช ืฉืื ืืืื ืงืื ืื ืขื ืืืืืืช ืขื ืงืืืช ืืื ื ืืงืจื ืฉืืืืฉ ืืื ืขืืืจ Hive.
ืืขืื ื ืืฆืืืจืช ื-GreenPlum ืชืืืื ืืืืื ืืืฉื ืื ืคื ืื ืชืื ืื ืฉื ืืขื ื ืืขืืจ, ืืืืื ืื ืืืืืช ืืืขื ืืืชืืฉืืช ืื ืืืจ. ืื ืงืจื ืืืืืช SQL Joins ืืืจืืืืงืืืจืช GreenPlum, ืืืืคืฉืจืช ืืช ืคืขืืืช ืืืืืงื.
ืื, GreenPlum ืืืกืืคื ืืช ืืืืชื ืืฉืืืช delete+sert, ืืื ื-Hive ืืื ืคืขืืืืช ืืืืงื ืื ืขืืืื, ืื ืฉืื ืืขืจื ืื ืชืื ืื ื ืืืฅ ืืืืืชื ืืืืฉ ืืืืืื ืืืืื ืขืืืื ืืฆืืืจ. ืืืฉืืืื ืืื ืืชืืื ืืืืืืฉืื ืืืืืฉื ืืื ืืืฉืคื ืืช ืืืืชืจ, ืืืืืื ืฉืืื ืืชืืืื ืืืืคืฆืื ืื ืคืืฆื ืืืืชืจ ืืฉืืืืฉ ืืืืจืืืช ืขืชืืจืืช ืืฉืืืื. ืื ื ืจืืืื ืฉ-GreenPlum ื ืืฆืื ืืช Hive ืืืืื ืืื ืคื 8.
ืขืืืื Ab Initio ืขื GreenPlum ืืืฆื ืงืจืื ืืืื ืืืช
ืื ืืกืื ืื, ื ืืืืง ืืช ืืืืืืช ืฉื Ab Initio ืืขืืื ืืช ืืืืช GreenPlum ืขื ื ืชืื ื ืชืื ืื ืฉื ืืฆืจื ืืืืคื ืืงืจืื ืืืขื ืืืื ืืืช. ืืืื ื ืืื ืืช ืืืืช GreenPlum dev42_1_db_usl.TESTING_SUBJ_org_finval, ืืืชื ื ืขืืื.
ื ืฉืชืืฉ ืืฉืืืฉื ืืจืคืื ืฉื Ab Initio ืืื ืืขืืื ืืืชื:
1) ืืจืฃ Create_test_data.mp - ืืืฆืจ ืงืืฆื ื ืชืื ืื ื-HDFS ืขื 10 ืฉืืจืืช ื-6 ืฉืจืฉืืจืื ืืงืืืืื. ืื ืชืื ืื ืื ืืงืจืืืื, ืืืื ื ืฉืืื ืืืืจืื ืืืื ืกื ืืืืื ืฉืื ื
2) ืืจืฃ mdw_load.day_one.current.dev42_1_db_usl_testing_subj_org_finval.pset - ืืจืฃ ืฉื ืืฆืจ ืขื ืืื MDW ืขื ืืื ืืชืืื ืืื ืกืช ืื ืชืื ืื ืืืืื ืฉืื ื ื-10 ืฉืจืฉืืจืื ืืงืืืืื (ื ืขืฉื ืฉืืืืฉ ืื ืชืื ื ืืืืงื ืฉื ืืฆืจื ืขื ืืื ืืจืฃ (1))
3) ืืจืฃ mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset - ืืจืฃ ืฉื ืืฆืจ ืขื ืืื MDW ืืขืืืื ืืฆืืืจ ืฉื ืืืืื ืฉืื ื ื-10 ืฉืจืฉืืจืื ืืงืืืืื ืชืื ืฉืืืืฉ ืืืืง ืฉื ื ืชืื ืื ืืจืืื ืฉืืชืงืืื (ืืืชื) ืฉื ืืฆืจื ืขื ืืื ืืจืฃ (1)
ืืืื ื ืจืืฅ ืืช ืืกืงืจืืคื ืฉืืืื ืืืฆื NRT:
- ืืืฆืืจ 6 ืงืืื ืืืืงื
- ืืฆืข ืขืืืก ืจืืฉืื ื ืืื ืก 6 ืฉืืจืืช ืืืืงื ืืืืื ืจืืงื
- ืืืืจ ืขื ืืืจืื ืืฆืืืจืช 5 ืคืขืืื
- ืืืฆืืจ 6 ืงืืื ืืืืงื
- ืืฆืข ืืืกืคื ืืฆืืืจืช ืฉื 6 ืฉืืจืืช ืืืืงื ืืืืื (ืืืงืจื ืื, ืืื ืืชืคืืื valid_to_ts ืืืืืจ ืื ืชืื ืื ืืืฉื ืื ืื ืชืื ืื ืขืืื ืืื ืืืชืจ ืขื ืืืชื ืืคืชื ืจืืฉื ืืืื ืกืื)
ืชืจืืืฉ ืื ืืืงื ืืช ืืืคื ืืคืขืืื ืืืืืชื ืฉื ืืขืจืืช ืขืกืงืืช ืืกืืืืช - ืืืง ืืืื ืืืื ืฉื ื ืชืื ืื ืืืฉืื ืืืคืืข ืืืื ืืืช ืื ืฉืคื ืืื ืืชืื GreenPlum.
ืขืืฉืื ืืืื ื ืกืชืื ืขื ืืืืื ืฉื ืืกืงืจืืคื:
ืืชืื ืืช Create_test_data.input.pset ื-2020-06-04 11:49:11
ืกืืื Create_test_data.input.pset ื-2020-06-04 11:49:37
ืืชืื ืืช mdw_load.day_one.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 11:49:37
ืกืืื ืืช mdw_load.day_one.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 11:50:42
ืืชืื ืืช Create_test_data.input.pset ื-2020-06-04 11:50:42
ืกืืื Create_test_data.input.pset ื-2020-06-04 11:51:06
ืืชืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 11:51:06
ืกืืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 11:53:41
ืืชืื ืืช Create_test_data.input.pset ื-2020-06-04 11:53:41
ืกืืื Create_test_data.input.pset ื-2020-06-04 11:54:04
ืืชืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 11:54:04
ืกืืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 11:56:51
ืืชืื ืืช Create_test_data.input.pset ื-2020-06-04 11:56:51
ืกืืื Create_test_data.input.pset ื-2020-06-04 11:57:14
ืืชืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 11:57:14
ืกืืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 11:59:55
ืืชืื ืืช Create_test_data.input.pset ื-2020-06-04 11:59:55
ืกืืื Create_test_data.input.pset ื-2020-06-04 12:00:23
ืืชืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 12:00:23
ืกืืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 12:03:23
ืืชืื ืืช Create_test_data.input.pset ื-2020-06-04 12:03:23
ืกืืื Create_test_data.input.pset ื-2020-06-04 12:03:49
ืืชืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 12:03:49
ืกืืื ืืช mdw_load.regular.current.dev42_1_db_usl_testing_subj_org_finval.pset ื-2020-06-04 12:06:46
ืืกืชืืจ ืฉืืชืืื ื ืืื:
ืืจืฃ
ืฉืขืช ืืชืืื
ืกืืื ืืืื
ืืืจื
Create_test_data.input.pset
04.06.2020 11: 49: 11
04.06.2020 11: 49: 37
00:00:26
mdw_load.day_one.current.
dev42_1_db_usl_testing_subj_org_finval.pset
04.06.2020 11: 49: 37
04.06.2020 11: 50: 42
00:01:05
Create_test_data.input.pset
04.06.2020 11: 50: 42
04.06.2020 11: 51: 06
00:00:24
mdw_load.regular.current.
dev42_1_db_usl_testing_subj_org_finval.pset
04.06.2020 11: 51: 06
04.06.2020 11: 53: 41
00:02:35
Create_test_data.input.pset
04.06.2020 11: 53: 41
04.06.2020 11: 54: 04
00:00:23
mdw_load.regular.current.
dev42_1_db_usl_testing_subj_org_finval.pset
04.06.2020 11: 54: 04
04.06.2020 11: 56: 51
00:02:47
Create_test_data.input.pset
04.06.2020 11: 56: 51
04.06.2020 11: 57: 14
00:00:23
mdw_load.regular.current.
dev42_1_db_usl_testing_subj_org_finval.pset
04.06.2020 11: 57: 14
04.06.2020 11: 59: 55
00:02:41
Create_test_data.input.pset
04.06.2020 11: 59: 55
04.06.2020 12: 00: 23
00:00:28
mdw_load.regular.current.
dev42_1_db_usl_testing_subj_org_finval.pset
04.06.2020 12: 00: 23
04.06.2020 12: 03: 23
00:03:00
Create_test_data.input.pset
04.06.2020 12: 03: 23
04.06.2020 12: 03: 49
00:00:26
mdw_load.regular.current.
dev42_1_db_usl_testing_subj_org_finval.pset
04.06.2020 12: 03: 49
04.06.2020 12: 06: 46
00:02:57
ืื ื ืจืืืื ืฉ-6 ืฉืืจืืช ืืฆืืืจืืช ืืขืืืืืช ื-000 ืืงืืช, ืืื ืื ืืืืจ.
ืื ืชืื ืื ืืืืืช ืืืขื ืืชืืจืจื ืืืืืืงืื ืืืืคื ืืื:
select valid_from_ts, valid_to_ts, count(1), min(sk), max(sk) from dev42_1_db_usl.TESTING_SUBJ_org_finval group by valid_from_ts, valid_to_ts order by 1,2;
ื ืืชื ืืจืืืช ืืช ืืืชืืื ืฉื ืื ืชืื ืื ืฉืืืื ืกื ืืืื ืื ืฉืืื ืืืฉืงื ืืืจืคืื.
ืื ืืืืจ ืฉืืชื ืืืื ืืืคืขืื ืืขืื ื ืืฆืืืจืช ืฉื ื ืชืื ืื ืืชืื GreenPlum ื-Ab Initio ืืชืืืจืืช ืืืืื ืืืื ืืืฆืคืืช ืืืืืจืืช ืืืืื ืฉื ืืื ืกืช ื ืชืื ืื ืืื ืืชืื GreenPlum. ืืืืื, ืื ื ืืชื ืืืื ืืืคืขืื ืคืขื ืืฉื ืืื, ืฉืื Ab Initio, ืืื ืื ืืื ETL, ืืืจืฉ ืืื "ืืืชืืื" ืืขืช ืืืฉืงื.
ืืกืงื ื
Ab Initio ืืฉืืฉ ืืืื ื-Sberbank ืืื ืืืช ืฉืืืช ื ืชืื ืื ืกืื ืืืช ืืืืืืช (ESS). ืคืจืืืงื ืื ืืืื ืื ืืืช ืืจืกื ืืืืืืช ืฉื ืืฆืื ืฉื ืืืคืื ืขืกืงืืื ืื ืงืืืื ืฉืื ืื. ืืืืืข ืืืืข ืืืงืืจืืช ืฉืื ืื, ืฉืืขืืชืงืื ืฉืืื ืืืื ืื ื-Hadoop. ืืืชืืกืก ืขื ืืฆืจืืื ืืขืกืงืืื, ืืืื ืื ืืืื ื ืชืื ืื ืืืชืืืจืื ืืจื ืกืคืืจืืฆืืืช ื ืชืื ืื. Ab Initio ืืืขื ืช ืืืืข ืืชืื ื-ESN ืืื ืชืื ืื ืฉืืืจืื ืื ืจืง ืืขื ืืื ืื ืืช ืืขืกืง ืืคื ื ืขืฆืื, ืืื ืื ืืฉืืฉืื ืืืงืืจ ืืื ืืืช Data March. ืืื ืขื ืืืช, ืืคืื ืงืฆืืื ืืืืช ืฉื ืืืืฆืจ ืืืคืฉืจืช ืฉืืืืฉ ืืืขืจืืืช ืฉืื ืืช ืืืงืื (Hive, Greenplum, Teradata, Oracle), ืื ืฉืืืคืฉืจ ืืืืื ื ืชืื ืื ืืขืกืง ืืงืืืช ืืคืืจืืืื ืืฉืื ืื ืฉืืื ืืืจืฉ.
ืืืืืืืช ืฉื Ab Initio ืจืืืืช; ืืืืืื, ืืกืืจืช ื-MDW ืืืืืื ืืืคืฉืจืช ืืื ืืช ื ืชืื ืื ืืืกืืืจืืื ืืื ืืื ืืขืกืงืืื ืืืืฅ ืืงืืคืกื. ืขืืืจ ืืคืชืืื, Ab Initio ืืืคืฉืจืช ืื ืืืืฆืื ืืช ืืืืื ืืืืฉ, ืืื ืืืฉืชืืฉ ืืจืืืืื ืคืื ืงืฆืืื ืืืื ืจืืื ืงืืืืื, ืฉืื ืืขืฆื ืกืคืจืืืช ืืืจืืฉืืช ืืขืืืื ืขื ื ืชืื ืื.
ืืืืชื ืืื ืืืืื ืืงืืืื ืืืงืฆืืขืืช ืฉื Sberbank SberProfi DWH/BigData. ืืงืืืื ืืืงืฆืืขืืช SberProfi DWH/BigData ืืืจืืืช ืืคืืชืื ืืืืื ืืืืช ืืชืืืืื ืืื ืืืงืืกืืกืื ืฉื Hadoop, Teradata, Oracle DB, GreenPlum, ืืื ืืื BI Qlik, SAP BO, Tableau ืืื'.
ืืงืืจ: www.habr.com