Enum gapi_grpc::google::cloud::bigquery::storage::v1beta1::ShardingStrategy [−][src]
Strategy for distributing data among multiple streams in a read session.
Variants
Same as LIQUID.
Assigns data to each stream based on the client’s read rate. The faster the client reads from a stream, the more data is assigned to the stream. In this strategy, it’s possible to read all data from a single stream even if there are other streams present.
Assigns data to each stream such that roughly the same number of rows can be read from each stream. Because the server-side unit for assigning data is collections of rows, the API does not guarantee that each stream will return the same number or rows. Additionally, the limits are enforced based on the number of pre-filtering rows, so some filters can lead to lopsided assignments.
Implementations
impl ShardingStrategy
[src]
pub fn is_valid(value: i32) -> bool
[src]
Returns true
if value
is a variant of ShardingStrategy
.
pub fn from_i32(value: i32) -> Option<ShardingStrategy>
[src]
Converts an i32
to a ShardingStrategy
, or None
if value
is not a valid variant.
Trait Implementations
impl Clone for ShardingStrategy
[src]
fn clone(&self) -> ShardingStrategy
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for ShardingStrategy
[src]
impl Debug for ShardingStrategy
[src]
impl Default for ShardingStrategy
[src]
fn default() -> ShardingStrategy
[src]
impl Eq for ShardingStrategy
[src]
impl From<ShardingStrategy> for i32
[src]
fn from(value: ShardingStrategy) -> i32
[src]
impl Hash for ShardingStrategy
[src]
fn hash<__H: Hasher>(&self, state: &mut __H)
[src]
pub fn hash_slice<H>(data: &[Self], state: &mut H) where
H: Hasher,
1.3.0[src]
H: Hasher,
impl Ord for ShardingStrategy
[src]
fn cmp(&self, other: &ShardingStrategy) -> Ordering
[src]
#[must_use]pub fn max(self, other: Self) -> Self
1.21.0[src]
#[must_use]pub fn min(self, other: Self) -> Self
1.21.0[src]
#[must_use]pub fn clamp(self, min: Self, max: Self) -> Self
1.50.0[src]
impl PartialEq<ShardingStrategy> for ShardingStrategy
[src]
fn eq(&self, other: &ShardingStrategy) -> bool
[src]
#[must_use]pub fn ne(&self, other: &Rhs) -> bool
1.0.0[src]
impl PartialOrd<ShardingStrategy> for ShardingStrategy
[src]
fn partial_cmp(&self, other: &ShardingStrategy) -> Option<Ordering>
[src]
#[must_use]pub fn lt(&self, other: &Rhs) -> bool
1.0.0[src]
#[must_use]pub fn le(&self, other: &Rhs) -> bool
1.0.0[src]
#[must_use]pub fn gt(&self, other: &Rhs) -> bool
1.0.0[src]
#[must_use]pub fn ge(&self, other: &Rhs) -> bool
1.0.0[src]
impl StructuralEq for ShardingStrategy
[src]
impl StructuralPartialEq for ShardingStrategy
[src]
Auto Trait Implementations
impl RefUnwindSafe for ShardingStrategy
impl Send for ShardingStrategy
impl Sync for ShardingStrategy
impl Unpin for ShardingStrategy
impl UnwindSafe for ShardingStrategy
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<Q, K> Equivalent<K> for Q where
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
[src]
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
pub fn equivalent(&self, key: &K) -> bool
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
pub fn into_request(self) -> Request<T>
[src]
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
[src]
V: MultiLane<T>,
impl<T> WithSubscriber for T
[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,