Search.setIndex({docnames:["_api/airflow/providers/apache/cassandra/hooks/cassandra/index","_api/airflow/providers/apache/cassandra/hooks/index","_api/airflow/providers/apache/cassandra/index","_api/airflow/providers/apache/cassandra/sensors/index","_api/airflow/providers/apache/cassandra/sensors/record/index","_api/airflow/providers/apache/cassandra/sensors/table/index","commits","connections/cassandra","index","installing-providers-from-sources","operators"],envversion:{"sphinx.domains.c":2,"sphinx.domains.changeset":1,"sphinx.domains.citation":1,"sphinx.domains.cpp":4,"sphinx.domains.index":1,"sphinx.domains.javascript":2,"sphinx.domains.math":2,"sphinx.domains.python":3,"sphinx.domains.rst":2,"sphinx.domains.std":2,"sphinx.ext.intersphinx":1,"sphinx.ext.viewcode":1,sphinx:56},filenames:["_api/airflow/providers/apache/cassandra/hooks/cassandra/index.rst","_api/airflow/providers/apache/cassandra/hooks/index.rst","_api/airflow/providers/apache/cassandra/index.rst","_api/airflow/providers/apache/cassandra/sensors/index.rst","_api/airflow/providers/apache/cassandra/sensors/record/index.rst","_api/airflow/providers/apache/cassandra/sensors/table/index.rst","commits.rst","connections/cassandra.rst","index.rst","installing-providers-from-sources.rst","operators.rst"],objects:{"airflow.providers.apache":[[2,0,0,"-","cassandra"]],"airflow.providers.apache.cassandra":[[1,0,0,"-","hooks"],[3,0,0,"-","sensors"]],"airflow.providers.apache.cassandra.hooks":[[0,0,0,"-","cassandra"]],"airflow.providers.apache.cassandra.hooks.cassandra":[[0,1,1,"","CassandraHook"],[0,4,1,"","Policy"]],"airflow.providers.apache.cassandra.hooks.cassandra.CassandraHook":[[0,2,1,"","conn_name_attr"],[0,2,1,"","conn_type"],[0,2,1,"","default_conn_name"],[0,3,1,"","get_cluster"],[0,3,1,"","get_conn"],[0,3,1,"","get_lb_policy"],[0,2,1,"","hook_name"],[0,3,1,"","record_exists"],[0,3,1,"","shutdown_cluster"],[0,3,1,"","table_exists"]],"airflow.providers.apache.cassandra.sensors":[[4,0,0,"-","record"],[5,0,0,"-","table"]],"airflow.providers.apache.cassandra.sensors.record":[[4,1,1,"","CassandraRecordSensor"]],"airflow.providers.apache.cassandra.sensors.record.CassandraRecordSensor":[[4,3,1,"","poke"],[4,2,1,"","template_fields"]],"airflow.providers.apache.cassandra.sensors.table":[[5,1,1,"","CassandraTableSensor"]],"airflow.providers.apache.cassandra.sensors.table.CassandraTableSensor":[[5,3,1,"","poke"],[5,2,1,"","template_fields"]]},objnames:{"0":["py","module","Python module"],"1":["py","class","Python class"],"2":["py","attribute","Python attribute"],"3":["py","method","Python method"],"4":["py","data","Python data"]},objtypes:{"0":"py:module","1":"py:class","2":"py:attribute","3":"py:method","4":"py:data"},terms:{"0":[0,1,2,3,4,5,7,9,10],"00642a46d":6,"008035450":6,"01":6,"02":6,"03":6,"04":6,"05":6,"06":6,"0646849e3":6,"07":6,"08":6,"09":6,"0a0e1af80":6,"0a6858847":6,"0b0e4f7a4":6,"0b2":6,"0beta1":6,"1":[0,1,2,3,4,5,7,9,10],"10":6,"10170":6,"10483":6,"10528":6,"10543":6,"11":[6,9],"11036":6,"11238":6,"11242":6,"11249":6,"11487":6,"11688":6,"11826":6,"11855":6,"12":[6,9],"12082":6,"12206":6,"12212":6,"12304":6,"12366":6,"12390":6,"12444":6,"12449":6,"12466":6,"12558":6,"12681":6,"12917":6,"12955":6,"12af6a080":6,"12c5e5d8a":6,"13":[6,8],"13073":6,"13148":6,"13380":6,"13767":6,"14":6,"14013":6,"14734":6,"14886":6,"15":6,"15518":6,"15576":6,"15667":[6,8],"16":6,"16294":6,"16405":6,"16464":6,"16501":6,"16682":6,"16869":6,"16e712971":6,"17":6,"17015":6,"17020":6,"17116":6,"17682":6,"17890":6,"18":6,"18620":[6,8],"19":6,"1fba5402b":6,"2":[0,1,2,3,4,5,7,9,10],"20":6,"2019":6,"2020":6,"2021":[6,9,10],"2037303ee":6,"21":6,"22":6,"23":6,"23rc1":6,"24":6,"25":6,"26":6,"28":6,"29":6,"295d66f91":6,"2a1":6,"2f2f89c14":6,"3":[0,1,2,3,4,5,6,7,8,9,10],"30":6,"32971a1a2":6,"33f0cd265":6,"349b0811c":6,"3696c34c2":6,"375d1ca22":6,"37681bca0":6,"3b3287d7a":6,"4":8,"406f":9,"40a2476a5":6,"49":9,"4d3a":9,"4d74ac211":6,"4e8f9cc8d":6,"4f1616392":6,"5090fb0c8":6,"512":9,"5220e4c38":6,"54":9,"5950":6,"59eb5de78":6,"5a439e84":6,"5c6e":9,"6":6,"6131":6,"6139":6,"6609":6,"6674":9,"6693":6,"6701":6,"6714":6,"6889a333c":6,"68e4c4dcb":6,"6cf76d7ac":6,"6e6526a0f":6,"7338":6,"750555f26":6,"76ed2a49c":6,"7820":6,"7825e8f59":6,"7d24b088c":6,"7e6372a68":6,"8":6,"807ad32c":6,"85a18e13d":6,"866a601b7":6,"872b1566a":6,"87f408b1e":6,"8807":6,"8886":6,"8891":6,"8898":6,"88bdcfa0d":6,"8994":6,"8ec4":9,"9026":6,"91f4d80ff":6,"92585ca4c":6,"9320":6,"9370":6,"9404":6,"9408":6,"9550":6,"9729":6,"9784":6,"97a429f9d":6,"9877":6,"9985":6,"9b39f2478":6,"9c94b72d4":6,"class":8,"default":[0,6,8],"do":9,"final":6,"function":[4,5,6],"import":[6,8,9],"new":6,"return":0,"static":0,"super":6,"while":[4,5],By:9,For:[0,4,5,6,7,9,10],If:[0,7,8,9],In:10,It:[7,9,10],TO:7,The:[0,4,5,7,9,10],There:[7,9],To:[0,9,10],about:[6,9],abov:9,ac2f72c98:6,ad:[6,8],add:6,ae7cb4a1:6,after:6,aip:6,airflow:[9,10],aka:9,all:[0,8],alreadi:9,also:9,amazon:6,an:[0,1,2,3,4,5,6,7,8,9,10],ani:[0,9],apach:9,apache_airflow_providers_apache_cassandra:9,api:8,appli:[6,8],apply_default:[6,8],ar:[7,8,9,10],argument:[6,7],asc:9,associ:0,august:6,auto:[6,8],autom:6,automat:8,avail:[7,9,10],b2a28d159:6,b40dffa08:6,b916b7507:6,ba4b:9,backport:6,balanc:[0,7],base:[0,4,5],basehook:0,basesensoroper:[4,5],bash:9,batch:6,bbc627a3d:6,bd90136aa:6,be75dcd39:6,being:7,belong:9,below:[9,10],bin:9,binari:9,black:6,broken:6,bst:9,buggfix:6,build:[6,9],c34ef853c:6,c7e5bce57:6,ca4238eb4:6,ca_cert:[0,7],call:[5,6],can:[0,7,8,9,10],candid:6,cassandra:9,cassandra_conn_id:[0,4,5],cassandra_default:[0,4,5,7],cassandra_record_sensor:10,cassandra_sensor:[4,5],cassandra_table_sensor:10,cassandrahook:[0,4,5,6],cassandrarecordsensor:[4,10],cassandratablesensor:[5,10],catchup:10,cbf8001d7:6,cde15c6e4d3a8ec4ecf4ba4b6674e08ad7de406f:9,cde1:9,certif:9,certifi:9,chang:6,changelog:6,chapter:9,charact:6,check:[0,4,5,6,9,10],checksum:9,child_load_balancing_polici:[0,7],child_load_balancing_policy_arg:[0,7],child_policy_nam:[0,7],choos:9,cleanup:6,close:0,cloud:10,cluster:[0,4,5,10],code:9,column:10,com:9,come:6,comma:[0,7],command:6,comment:6,commit:6,commod:10,compat:6,complet:8,compromis:10,config:0,configur:10,conn:[6,8],conn_config:6,conn_name_attr:0,conn_typ:0,connect:[0,4,5,6,8,10],consist:6,contact:0,contain:[0,4,5,9],context:[4,5],correct:9,cql:[7,10],cql_version:7,creat:[0,4,5,9],critic:10,cross:6,curl:9,d02ded65:6,d0e7db402:6,d200:6,d7de:9,d:9,dag:[6,8,10],dag_id:10,data:[6,10],databas:[7,10],datacent:10,datetim:10,db:8,dcawareroundrobinpolici:[0,7],decor:[6,8],default_arg:[6,10],default_conn_nam:[0,4,5],defin:[4,5],dep:9,depend:6,deriv:[4,5],describ:9,descript:6,dest:9,detail:[0,6,7,8,9],dev0:[0,1,2,3,4,5,6,7,8,9,10],dev:6,dict:[0,4,7],dictionari:7,diff:9,differ:[0,7,9],directori:9,disabl:6,discoveri:6,distribut:[9,10],doc:6,document:[6,8],dot:[0,4,5,10],down:9,download:9,driver:[7,8],drop:9,due:8,dynam:6,e08a:9,each:4,ecf4:9,echo:9,ee7ca128a:6,enabl:[0,6,7],enforc:6,escap:6,essenti:9,exampl:[0,4,5,6,8,9],example_cassandra_dag:10,example_cassandra_oper:10,example_dag:[6,10],exist:[0,4,5,8,10],experiment:[0,1,2,3,4,5,6,7,8,9,10],extra:0,f3521fb0e:6,f6bd817a3:6,f88f06c86:6,f987646d7:6,fals:10,fault:10,fdd9b6f65:6,featur:[0,1,2,3,4,5,6,7,9,10],few:7,field:[0,6],file:[6,8,9],fingerprint:9,first:8,fix:6,folder:9,follow:[4,5,7,9],form:6,formmatt:6,found:10,foundat:9,four:7,fresh:6,from:[6,8],further:10,gener:6,get:9,get_clust:0,get_conn:0,get_lb_polici:0,given:10,gmail:9,good:9,gpg:9,grammar:6,guid:[4,5,6,9],gz:9,ha:4,hardwar:10,hash:6,have:8,high:[6,10],hook:[2,6,7],hook_nam:0,host1:[0,7],host2:[0,7],host3:[0,7],host:[0,7],how:[4,5,9],http:[6,7,9],i:9,id:[4,5,6,8,9],identifi:10,implement:6,improv:6,includ:6,increas:6,indic:9,individu:6,inform:[4,5,6,10],infrastructur:10,initi:8,instal:6,instanti:[4,5],instruct:9,integr:[0,6],interact:[0,6],introduc:6,issuer:9,json:[6,7],juli:6,june:6,k:[4,5],ka:9,kaxil:9,kaxilnaik:9,keep:6,kei:[0,4,9,10],keyspac:[0,4,5,7,10],keyspace_nam:10,keyword:6,know:9,kwarg:[0,4,5,7],l:9,la:9,languag:10,latenc:10,latest:6,lazili:6,lb:[0,7],least:8,left:9,level:6,linear:10,link:[6,9],list:[6,7,8],load:[0,7],load_balancing_polici:[0,7],load_balancing_policy_arg:[0,7],local:9,local_dc:[0,7],local_dc_nam:[0,7],log:0,logging_mixin:0,loggingmixin:0,login:7,look:[4,5,10],lower:10,ls:9,made:9,magic:6,main:9,make:[6,10],manag:[6,9],manual:8,markdown:6,match:[6,9],maximum:7,mention:10,meta:6,migrat:8,mirror:9,mission:10,mktemp:9,modul:6,monitor:4,month:6,more:[4,5,6],most:9,move:6,multi:10,multipl:7,must:10,mypi:6,naik:9,name:[0,6,7],nativ:7,need:10,none:[9,10],nosql:10,notat:[0,4,5,10],note:6,number:6,o:9,object:0,octob:6,offer:10,offici:9,onc:9,one:9,onli:6,open:10,oper:[4,5,6,7,8],optimis:8,option:[0,7],org:[7,9],origin:9,otherwis:8,our:6,out:[6,7],overrid:[4,5],owner:9,p1:[4,10],p2:[4,10],package_nam:9,package_vers:9,page:[6,9],pair:10,paramet:[0,4,5,7,10],pass:[0,7],password:7,path:[6,7],path_to_ca_cert:0,per:6,perfect:10,perform:10,pgp:9,pgpk:9,pgpv:9,pip:[6,9],platform:10,pleas:9,point:[0,6],poke:[4,5,10],polici:[0,7],policy_arg:0,policy_nam:0,popul:4,port:[0,7],possibl:7,prepar:6,previou:9,primari:[4,9],project:[6,7],protocol:7,protocol_vers:[6,7],provid:[9,10],provider_download_dir:9,py3:9,py:10,pydocstyl:6,pylint:6,pypi:[6,7,8],python:[6,7,8,9],queri:10,rc2:6,rc3:6,re:10,readm:[6,8],recommend:9,record:[0,2,3],record_exist:0,record_sensor:10,ref:6,refernc:6,regener:6,relas:6,relat:7,releas:[6,8],relev:9,rema:6,remain:6,remov:[6,8,9],renam:6,replic:10,repositori:8,requir:7,roundrobinpolici:[0,7],rsa:9,run:[8,9],s:[6,7,9],sampl:7,sat:9,scalabl:10,schedule_interv:10,schema:7,script:[6,9],sdist:9,see:[0,6],select:[9,10],self:[0,4,5,9],sensor:[2,6,8],sep:9,separ:[0,6,7],sequenc:[4,5],server:9,session:0,set:10,setup:6,sha512:9,sha:9,shasum:9,should:[4,5,9],shutdown_clust:0,sign:9,signatur:[6,9],softwar:9,some_int_valu:[0,7],sourc:[0,4,5,8,10],space:6,specif:[0,4,5,10],specifi:[0,7],ssl:[0,7],ssl_option:[0,7],standard:7,start_dat:[6,10],statement:10,step:9,stop:6,str:[0,4,5],string:0,subject:6,sum:9,support:[6,7,10],synchron:6,t:[4,5],tabl:[0,2,3,4],table_exist:0,table_nam:10,table_sensor:10,tag:10,take:[4,5],tar:9,target:[0,4,5,10],task_id:[4,5,10],template_field:[4,5],temporari:9,thi:[0,1,2,3,4,5,6,7,8,9,10],those:9,toc:6,tokenawarepolici:[0,7],toler:10,tool:6,toolchain:6,top:[8,9],transfer:6,trust:9,type:[6,7,8],typo:6,unknown:9,until:10,up:6,updat:[6,8],upgrad:[6,8],us:[0,4,5,6,7,9],used_hosts_per_remote_dc:[0,7],user:[7,9],utf:6,util:0,v1:[4,10],v2:[4,10],valid:9,valu:[0,4,6,8,10],version:[6,7,8,9],via:[8,9],wait:[4,5],want:[4,5,8,9],warn:[6,9],wave:6,we:10,well:9,when:[4,5,6,10],which:10,whitelistroundrobinpolici:[0,7],whl:9,why:9,without:10,word:6,worri:9,wrap_socket:[0,7],wrong:6,wrongli:6,xcomarg:6,you:[4,5,8,9,10],your:8},titles:["<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.cassandra.hooks.cassandra</span></code>","<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.cassandra.hooks</span></code>","<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.cassandra</span></code>","<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.cassandra.sensors</span></code>","<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.cassandra.sensors.record</span></code>","<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.cassandra.sensors.table</span></code>","Package apache-airflow-providers-apache-cassandra","Apache Cassandra Connection","<code class=\"docutils literal notranslate\"><span class=\"pre\">apache-airflow-providers-apache-cassandra</span></code>","Installing from sources","Apache Cassandra Operators"],titleterms:{"0":[6,8],"1":[6,8],"2":[6,8],"break":8,"class":[0,4,5],"default":7,airflow:[0,1,2,3,4,5,6,8],apach:[0,1,2,3,4,5,6,7,8,10],attribut:0,cassandra:[0,1,2,3,4,5,6,7,8,10],chang:8,changelog:8,commit:8,configur:7,connect:7,content:[0,4,5,8],creat:10,exampl:[7,10],extra:7,featur:8,field:7,from:9,guid:8,hook:[0,1],id:7,instal:[8,9],integr:9,misc:8,modul:[0,4,5],oper:10,packag:[6,8,9],pip:8,prerequisit:10,provid:[0,1,2,3,4,5,6,8],pypi:9,record:[4,10],refer:[8,10],releas:9,requir:8,resourc:8,sensor:[3,4,5,10],sourc:9,submodul:[1,3],subpackag:2,tabl:[5,10],us:10,verifi:9,wait:10}})