Граф коммитов

51 Коммитов

Автор SHA1 Сообщение Дата
Ramachandran A G f696d0f18f
* Fix scala format (#363)
* Add a scala formatter
2024-02-05 16:15:37 +05:30
ohad bitton 143a4a0cac
Spark ingestion properties clone (#330)
* Fix Spark ingestion properties clone
* Fix creation time for extents move

---------

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
2023-08-08 17:26:06 +05:30
Ramachandran A G e6e251a347
* Update trident sample (#305) 2023-04-19 16:03:25 +05:30
Ramachandran A G d4e57fb13c
* Added a ReadWrite sample for Trident (#297)
* * Added a ReadWrite sample for Trident

* * Fix comments
2023-03-23 17:52:43 +05:30
ohad bitton 3a47f8f159
Python samples README 2022-12-28 18:23:56 +02:00
ohad bitton efbb599e8e
Update pyKusto.py 2022-08-09 18:25:20 +03:00
ohad bitton ef69579fc1
Polling and Move extents as spark job (#243)
* one try

* better

* beter

* new option

* fix build

* comments

* fix

* log

* Update docs/KustoSink.md

Co-authored-by: Yochai Gilad <yogilad@microsoft.com>

* switch true and false

* renaming and logs

* fix

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
Co-authored-by: Yochai Gilad <yogilad@microsoft.com>
2022-07-21 12:46:47 +03:00
ohad bitton 5670ff3645
Fix bugs and upgrade to sdk v3.1.1 (#242)
* Fix bugs and upgrade to sdk v3.1.1

* revert

* revert test

* fix build

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
2022-06-21 07:04:27 +03:00
Hauke Mallow 6801ebe51b
Data pre-processing example notebooks (#210)
* Azure Databricks python notebook pre-processing 

Azure Databricks python notebook Data pre-processing for Azure Data Explorer

* Azure Synapse pre-processing example

Azure Synapse python notebook 
Data pre-processing for Azure Data Explorer

* Update samples/src/main/synapse/pre-process-json-2-ADX.ipynb

Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>

* Update samples/src/main/synapse/pre-process-json-2-ADX.ipynb

Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>

* Update samples/src/main/synapse/pre-process-json-2-ADX.ipynb

Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>

* Update pre-process-json-2-ADX.ipynb

spark conf settings are not necessary, added a comment, that this is not needed for anonymous access, commented out the line (if customers want to access there data they need it, and notebook should show how to do so)

* Operationalize your Spark ML model into Data Explorer pool for scoring

Azure Synapse Analytics - Operationalize your Spark ML model into Data Explorer pool for scoring
Example notebook with ML model training on Spark and scoring on Data Explorer pool

Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>
2022-06-02 20:49:53 +03:00
Manoj Raheja 9bac87a3db
Update SynapseSample.py (#219)
* Update SynapseSample.py

Added notes for            #.option("authType", "LS")

* Update samples/src/main/python/SynapseSample.py

Co-authored-by: Yihezkel Schoenbrun <yihezkel@schoenbrun.net>

* Update samples/src/main/python/SynapseSample.py

Co-authored-by: Yihezkel Schoenbrun <yihezkel@schoenbrun.net>

* Update samples/src/main/python/SynapseSample.py

Co-authored-by: Yihezkel Schoenbrun <yihezkel@schoenbrun.net>

* Update samples/src/main/python/SynapseSample.py

Co-authored-by: Yihezkel Schoenbrun <yihezkel@schoenbrun.net>

Co-authored-by: Yihezkel Schoenbrun <yihezkel@schoenbrun.net>
Co-authored-by: Yihezkel Schoenbrun <yischoen@microsoft.com>
Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>
2022-05-31 20:23:55 +03:00
ohad bitton 7d1ca81889
Python sdk synapse Authentication sample (#230)
* sample

* better

* better

* Update samples/src/main/python/SynapsePythonSDK.py

Co-authored-by: Yihezkel Schoenbrun <yischoen@microsoft.com>

* Update samples/src/main/python/SynapsePythonSDK.py

Co-authored-by: Yihezkel Schoenbrun <yischoen@microsoft.com>

* Update samples/src/main/python/SynapsePythonSDK.py

Co-authored-by: Yihezkel Schoenbrun <yischoen@microsoft.com>

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
Co-authored-by: Yihezkel Schoenbrun <yischoen@microsoft.com>
2022-03-22 15:13:16 +02:00
Yihezkel Schoenbrun 5cda0adfe9
Add support for Materialized Views (#221)
* Add support for Materialized Views by using new SetNewIngestionTime feature in such cases

* Fix command (SetNewIngestionTime is part of 'with')

* Verbiage fixes, per code review

* Per formatting request from Asaf

* Trivial change to trigger new CI build
2022-03-13 23:09:33 +02:00
ohad bitton f8c40d6eda
Transient storage list (#211)
* first try

* better

* better

* better

* better

* revert

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
2021-11-07 09:18:02 +02:00
ohad bitton 1836405e56
Document customSchema (#199)
* document customSchema

* Update samples/src/main/python/pyKusto.py

Co-authored-by: Yochai Gilad <yogilad@microsoft.com>

* Update pyKusto.py

* Update pyKusto.py

Co-authored-by: Yochai Gilad <yogilad@microsoft.com>
2021-08-03 15:02:14 +03:00
ohad bitton fdc9fcb944
Extents move batches (#192)
* Revert "Revert "New option for the auto delete policy time - apart from the timeout with default of 7 days Make sure we use the same client request properties in all the flow Small bug fix - not allowed url to contain "ingest-"""

This reverts commit 9bccb17a

* better

* commetns

* move extents by batches

* move extents by batches

* debug

* debug

* writer clean

* better

* writer clean

* better count per yoni suggestion

* fix

Co-authored-by: KustoIbizaExtension Build <kustodev@microsoft.com>
2021-06-22 15:07:11 +03:00
KustoIbizaExtension Build a9db6ef624 2.7.4 2021-06-02 11:27:36 +03:00
ohad bitton cf9f032118 2.7.0 2021-04-20 15:02:20 +03:00
ohad bitton 7ba94ae010
Migrate to Msal (#177)
* msal

* msal

* device

* msal  devic

* msal  devic

* msal  device

* msal  device

* pom fix

* comments

* comments

* comments
2021-04-11 11:52:20 +03:00
Manoj Raheja d0b3cfc2e6
Create SynapseSample.py (#153)
* Create SynapseSample.py

Added Sample file for Synapse

* Update samples/src/main/python/SynapseSample.py

Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>

* Update SynapseSample.py

Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>
2020-10-12 19:08:49 +03:00
ohad bitton 03950f4618
spark 3 scala 2.12 support (#152)
* spark 3 scala 2.12

* readme

* docs

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
2020-09-30 10:06:59 +03:00
Ohad Bitton 4737914261 docs - new version and remove unnecessary wholestage conf 2020-09-15 11:53:27 +03:00
ohad bitton f6c19883e6
Update pyKusto.py 2020-07-10 16:39:57 +03:00
ohad bitton 498f86f3b4
Python sample and strings for python users (#135)
* sample

* docs with strings

* Change authentication naming to app id and secret

* Change authentication naming to app id and secret

* Change authentication naming to app id and secret

* Change authentication naming to app id and secret

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
2020-06-29 10:26:38 +03:00
ohad bitton 0f05ead00f
Docs (#130)
* better

* better

* remove storage providing from docs

* version

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
2020-06-03 21:05:05 +03:00
Manoj Raheja 409f2dabe3
Fixed the typo for the Device Authentication code (#124)
changed 
deviceCodeMessage = deviceAuth.getDeviceCodeMassage() 
to 
deviceCodeMessage = deviceAuth.getDeviceCodeMessage()
2020-05-08 15:44:41 +03:00
ohad bitton 61d94cdb47
Pyspark device authentication (#117)
* bump versio

* Device authentication class for easy use in pyspark

* aad

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
2020-04-12 14:29:20 +03:00
ohad bitton d32812e425
Export containers (#102)
* use export containers
introduce READ_MODE to choose scale or lean mode

* use export storage

* use export storage

* Update KustoSourceE2E.scala

* fix

* multiple storage accounts

* multiple storage accounts

* fix build

* comments

* comments

* comment

* comment

* comment

* rename and docs

Co-authored-by: ohbitton <42732233+ohbitton@users.noreply.github.com>
2020-02-18 14:31:33 +02:00
Ohad Bitton e0c910e501 fix provided scope 2019-09-01 13:39:07 +03:00
ohadbitt 25badfb68b
Bug fixes , logging and small upgrades (#86)
* This commit has many changes.
Entered a breaking change that make the user specify SaveMode.Append as before we logged the specified save mode and ignored, docs were updated accordingly.
A few bugs were fixed :
 timeout bug - was waiting 1 second for finish ?!
 authentication failed when application only had reading permissions due to creation of ingestClient without needing it
 ClientRequestProperties bug
Upgrades:
 Reading parquet.snappy format as spark utilize it better
 Ingestion is done once file is ready and not when all files are ready
 Sas is saved and not created from the container object
Logging:
 used to log only the exception message - now the full stacktrace is logged

* clientRequestProperties from new java version

* return the result!

* fix PR comments

* fix PR comments
2019-08-29 18:19:07 +03:00
ohadbitt 0d349d1e7a
Docs (#76)
* docs

* docs

* docs

* docs

* Update docs/KustoSink.md

Co-Authored-By: Daniel Dubovski <dadubovs@microsoft.com>

* Update docs/KustoSink.md

Co-Authored-By: Daniel Dubovski <dadubovs@microsoft.com>

* Update docs/KustoSink.md

Co-Authored-By: Daniel Dubovski <dadubovs@microsoft.com>

* Update docs/KustoSink.md

Co-Authored-By: Daniel Dubovski <dadubovs@microsoft.com>

* allow ClientRequestProperties and ingestionProperties from python
2019-06-24 16:08:33 +03:00
ohadbitt 8f755a4291
ClientRequestPropertiesAndIngestionProperties (#68)
* ClientRequestPropertiesAndIngestionProperties

* ClientRequestProperties And IngestionProperties

* split KustoOptions to KustoSourceOPtions and KustoSinkOptions

* fix maven compilation failure

* move kustoOptions to common package
2019-06-05 17:50:19 +03:00
michazag a1cc74e38d Remove a misleading comment
This change was already committed on master, so it will make dev aligned to master
2019-04-30 17:52:17 +03:00
michazag 0b65416f33 Styling and fixes 2019-04-18 11:46:51 +03:00
michazag 9244e338d3 Remove blobSetFsConfig option.
Instead, cache and set if missing
2019-04-16 17:51:03 +03:00
michazag d4699fc405 Remove reading mode parameter
Replace with internal heuristics.
Can be overridden by a debug flag mostly for debug and testing
2019-04-15 18:11:15 +03:00
michazag 7283cefc85 Scala from provided to compile scope 2019-03-19 14:50:05 +02:00
michazag 95d4bb1f6c Fix dependency issues 2019-03-19 13:27:55 +02:00
michazag 729c38a1a6 Merge branch 'dev' into Clean-up-dependencies 2019-03-19 13:08:53 +02:00
michazag 8548b3c324 Organize dependencies 2019-03-19 11:23:06 +02:00
Michael Zagalsky 3d5ae20d98
Update samples/src/main/scala/KustoConnectorDemo.scala 2019-03-19 11:14:22 +02:00
Michael Zagalsky 90cd06b074
Merge branch 'dev' into Release1903ValidationFixes 2019-03-19 09:12:46 +02:00
Tamir Kamara 0ba9d27e32
Update Kusto SDK dependency to 1.0.0-BETA-04 from Maven
* use kusto-sdk from maven
* gitignore update
* remove unused properties from connector POM
2019-03-18 13:48:25 +01:00
Nava Vaisman Levy dd74ac8f83
Merge branch 'dev' into spark-streaming 2019-03-18 09:33:05 +02:00
michazag 4e01e68ee7 Fix key vault parameters when using account id and key
Also update KustoConnectorDemo reference (based on databricks notebook)
2019-03-17 19:00:12 +02:00
Ohad Bitton e2441852f1 Merge branches 'dev' and 'small-fix-tmp-storage' of https://github.com/Azure/azure-kusto-spark into small-fix-tmp-storage
# Conflicts:
#	connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala
#	connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoClient.scala
2019-03-13 11:07:40 +02:00
michazag 98b3bececa Update changelog with main changes 2019-03-10 17:50:10 +02:00
Nava Vaisman Levy 4e4d7413d0 use defaut 2019-03-06 13:54:46 +02:00
Nava Vaisman Levy bada1bb4bc update readme 2019-03-06 12:38:35 +02:00
Ohad Bitton 40c156c1af fix tmp storage
cached client

cached client

cached client
2019-03-06 11:39:53 +02:00
Nava Vaisman Levy cdc17ace10 update readme, update streaming sample 2019-03-05 16:44:49 +02:00