MCPcopy Create free account

hub / github.com/cata-network/cata_database / functions

Functions323 in github.com/cata-network/cata_database

↓ 1 callersMethodgetMyself
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSContext.java:60
↓ 1 callersMethodgetName
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriter.java:51
↓ 1 callersMethodgetNewLineDelimiter
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:93
↓ 1 callersMethodgetNumWorkerThreads
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:120
↓ 1 callersMethodgetPartialRootHash
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:409
↓ 1 callersMethodgetPort
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:104
↓ 1 callersMethodgetPos
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:111
↓ 1 callersMethodgetPos
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:160
↓ 1 callersMethodgetQuote
Returns the character used for escaping values where the field delimiter is part of the value. Defaults to '"' @return the quote character
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:101
↓ 1 callersMethodgetQuote
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextFormatConfig.java:28
↓ 1 callersMethodgetQuoteEscape
Returns the character used for escaping quotes inside an already quoted value. Defaults to '"' @return the quote escape character
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:131
↓ 1 callersMethodgetRecordCount
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:52
↓ 1 callersMethodgetRecordCount
Return the total number of records (across batches) processed
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextOutput.java:71
↓ 1 callersMethodgetSchema
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:62
↓ 1 callersMethodgetStoragePlugin
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSContext.java:64
↓ 1 callersMethodgetTargetHash
(IPFSHelper helper)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:149
↓ 1 callersMethodhandleException
Helper method to handle exceptions caught while processing text files and generate better error messages associated with the exception. @param ex Exc
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:423
↓ 1 callersMethodhasDrillbitAddress
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSPeer.java:44
↓ 1 callersMethodinit
(Map<String, String> writerOptions)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:41
↓ 1 callersMethodinit
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:89
↓ 1 callersMethodisDrillReady
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSPeer.java:36
↓ 1 callersMethodisHeaderExtractionEnabled
Indicates whether or not the first valid record parsed from the input should be considered as the row containing the names of each column @return true
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:221
↓ 1 callersMethodisIgnoreLeadingWhitespaces
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:269
↓ 1 callersMethodisIgnoreTrailingWhitespaces
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:277
↓ 1 callersMethodisParseUnescapedQuotes
Indicates whether the CSV parser should accept unescaped quotes inside quoted values and parse them normally. Defaults to {@code true}. @return a flag
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:204
↓ 1 callersMethodisSkipFirstLine
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:64
↓ 1 callersMethodisSkipFirstLine
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextFormatConfig.java:64
↓ 1 callersMethodisUseRepeatedVarChar
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:72
↓ 1 callersMethoditerator
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:99
↓ 1 callersMethodmark
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:164
↓ 1 callersMethodof
(String which)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:52
↓ 1 callersMethodparseField
Captures the entirety of parsing a single field and based on the input delegates to the appropriate function @return @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:305
↓ 1 callersMethodparsePath
(String path)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:113
↓ 1 callersMethodparseQuotedValue
Recursive function invoked when a quote is encountered. Function also handles the case when there are non-white space characters in the field after th
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:224
↓ 1 callersMethodparseRecord
Function encapsulates parsing an entire record, delegates parsing of the fields to parseField() function. We mark the start of the record and if there
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:123
↓ 1 callersMethodparseValue
Function simply delegates the parsing of a single field to the actual implementation based on parsing config @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:209
↓ 1 callersMethodparseValueAll
Function parses an individual field and appends all characters till the delimeter (or newline) to the output, including white spaces @throws IOExcepti
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:191
↓ 1 callersMethodparseValueIgnore
Function parses an individual field and ignores any white spaces encountered by not appending it to the output vector @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:171
↓ 1 callersMethodread
read some more bytes from the stream. Uses the zero copy interface if available. Otherwise, does byte copy. @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:173
↓ 1 callersMethodresetForNextBatch
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:107
↓ 1 callersMethodrowHasData
Helper method to check if the current record has any non-empty fields
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextOutput.java:86
↓ 1 callersMethodseek
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/SeekableByteArrayInputStream.java:44
↓ 1 callersMethodsetExecutorService
(ExecutorService executorService)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:66
↓ 1 callersMethodsetHeaderExtractionEnabled
Defines whether or not the first valid record parsed from the input should be considered as the row containing the names of each column @param headerE
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:229
↓ 1 callersMethodsetHolder
(SchemaPlus pulsOfThis)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:50
↓ 1 callersMethodsetMaxPeersPerLeaf
(int maxPeersPerLeaf)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:78
↓ 1 callersMethodsetMyself
(IPFSPeer myself)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:74
↓ 1 callersMethodsetOnEndpoint
(DrillbitEndpoint endpointAddress)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:411
↓ 1 callersMethodsetTimeouts
(Map<IPFSTimeOut, Integer> timeouts)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:70
↓ 1 callersMethodsetupNewSchema
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:173
↓ 1 callersMethodstartBatch
Informs output to setup for new record batch.
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextOutput.java:76
↓ 1 callersMethodstop
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:40
↓ 1 callersMethodupdateLengthBasedOnConstraint
Checks to see if we can go over the end of our bytes constraint on the data. If so, adjusts so that we can only read to the last character of the fir
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:233
↓ 1 callersMethodupdateRunningCount
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordReader.java:198
↓ 1 callersMethodupdateSchema
(VectorAccessible batch)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:50
↓ 1 callersMethodvalidateSymbol
(String header)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/HeaderBuilder.java:103
MethodDefaultWeakReference
(T referent, T default_)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:45
MethodFieldVarCharOutput
We initialize and add the varchar vector for each incoming field in this constructor. @param outputMutator Used to create/modify schema @param fieldN
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/FieldVarCharOutput.java:79
MethodFormat
(String prefix)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:68
MethodIPFSAggWriterPrule
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSAggWriterPrule.java:15
MethodIPFSContext
(IPFSStoragePluginConfig config, IPFSStoragePlugin plugin, IPFS client)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSContext.java:35
MethodIPFSGroupScan
(@JsonProperty("IPFSScanSpec") IPFSScanSpec ipfsScanSpec, @JsonProperty("IPFSStoragePlu
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:65
MethodIPFSHelper
(IPFS ipfs)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:61
MethodIPFSJSONRecordReader
(FragmentContext fragmentContext, IPFSContext ipfsContext, String scanSpec, List<SchemaPath> columns)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordReader.java:50
MethodIPFSJSONRecordWriter
(OperatorContext context, IPFSContext ipfsContext, String name)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:30
MethodIPFSPeer
(IPFSHelper helper, Multihash id)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSPeer.java:21
MethodIPFSScanSpec
(@JacksonInject StoragePluginRegistry registry, @JsonProperty("IPFSStoragePluginConfig"
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:96
MethodIPFSSchemaFactory
(IPFSContext context, String name)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:29
MethodIPFSStoragePlugin
(IPFSStoragePluginConfig config, DrillbitContext context, String name)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePlugin.java:30
MethodIPFSStoragePluginConfig
( @JsonProperty("host") String host, @JsonProperty("port") int port, @JsonProperty("ma
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:78
MethodIPFSSubScan
(@JacksonInject StoragePluginRegistry registry, @JsonProperty("IPFSStoragePluginConfig")
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:44
MethodIPFSSubScanSpec
(@JsonProperty("targetHash") String targetHash)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:122
MethodIPFSTables
(String name)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:45
MethodIPFSTextRecordReader
(IPFSContext ipfsContext, Multihash targetHash, TextParsingSettings settings, List<SchemaPath> columns)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/IPFSTextRecordReader.java:47
MethodIPFSTimeOut
(String which)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:48
MethodIPFSTreeFlattener
(Multihash hash, boolean isProvider)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:105
MethodIPFSWork
(String root)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:401
MethodIPFSWriter
( @JsonProperty("child") PhysicalOperator child, @JsonProperty("name") String name, @JsonPro
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriter.java:23
MethodIPFSWriterRecordBatch
(Writer writer, RecordBatch incoming, FragmentContext context, RecordWriter recordWriter, boolean isForeman)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:39
MethodPrefix
(String prefix)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:38
MethodRepeatedVarCharOutput
We initialize and add the repeated varchar vector to the record batch in this constructor. Perform some sanity checks if the selected columns are vali
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:118
MethodSeekableByteArrayInputStream
(byte[] recommendationBytes)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/SeekableByteArrayInputStream.java:36
MethodStreamFinishedPseudoException
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/StreamFinishedPseudoException.java:24
MethodTextInput
Creates a new instance with the mandatory characters for handling newlines transparently. lineSeparator the sequence of characters that represent a ne
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:93
MethodTextParsingContext
(TextInput input, TextOutput output)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:32
MethodTextReader
The CsvParser supports all settings provided by {@link CsvParserSettings}, and requires this configuration to be properly initialized. @param settings
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:73
Methodaccept
( PhysicalVisitor<T, X, E> physicalVisitor, X value)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:93
Methodappend
(byte data)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:270
Methodappend
(byte data)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/FieldVarCharOutput.java:169
Methodapply
(@Nullable SchemaPath path)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/IPFSTextRecordReader.java:60
MethodapplyAssignments
(List<DrillbitEndpoint> incomingEndpoints)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:306
MethodcanPushdownProjects
(List<SchemaPath> columns)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:368
MethodcheckForNewPartition
(int index)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:56
Methodclone
(List<SchemaPath> columns)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:360
Methodclose
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:227
Methodclose
Invoked once there are no more records and we are done with the current record reader to clean up state. @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:497
Methodclose
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:360
MethodcolumnsReordered
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:117
MethodcompareTo
(CompleteWork o)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:425
Methodcompute
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:110
← previousnext →101–200 of 323, ranked by callers